RabbitMQ入门:在Spring Boot 应用中整合RabbitMQ

在上一篇随笔中我们认识并安装了RabbitMQ,接下来我们来看下怎么在SpringBoot应用中整合RabbitMQ。先给出最终目录结构:搭建步骤如下:切换到amqp应用的控制台,能看到打印

大家好,又见面了,我是全栈君。

在上一篇随笔中我们认识并安装了RabbitMQ,接下来我们来看下怎么在Spring Boot 应用中整合RabbitMQ。

先给出最终目录结构:

RabbitMQ入门:在Spring Boot 应用中整合RabbitMQ

 

搭建步骤如下:

  1. 新建maven工程amqp
  2. 修改pom文件,引入spring-boot-starter-amqp和spring-boot-starter-test
    <project xmlns="http://maven.apache.org/POM/4.0.0"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <groupId>com.sam</groupId>
        <artifactId>amqp</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>1.5.1.RELEASE</version>
        </parent>
    
        <properties>
            <javaVersion>1.8</javaVersion>
        </properties>
        <dependencies>
            <!-- 引入amqp依赖,它能很好的支持RabbitMQ -->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-amqp</artifactId>
            </dependency>
            <!-- 引入test依赖,这次需要用到JUnit -->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
            </dependency>
        </dependencies>
    </project>

  3. 新建application.properties配置文件,主要就是配置下连接RabbitMQ的信息:
    spring.application.name=rabbitmq-hello
    #config rabbitmq info
    spring.rabbitmq.host=localhost
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest

  4. 新建启动类,这里没什么特殊的,就是普通的spring boot启动类
    /**
     * 这里没什么特殊的地方,就是普通的spring boot 配置
     *
     */
    @SpringBootApplication
    public class RabbitMQApp {
    
        public static void main(String[] args) {
            SpringApplication.run(RabbitMQApp.class, args);
        }
    }

  5. 创建生产者类,通过AmqpTemplate实现消息的发送,AmqpTemplate接口定义了一套针对AMQP协议的基础操作。在Spring Boot中会根据配置来注入具体的实现。这里我们会产生一个字符串,并发送到名为hello的队列中。
    @Component
    public class Sender {
    
        @Autowired
        AmqpTemplate rabbitmqTemplate;
    
        /**
         * 发送消息
         */
        public void send() {
            String content = "Sender says:" + "'hello, I'm sender'";
            System.out.println(content);
            rabbitmqTemplate.convertAndSend("hello", content);
        }
    }

  6. 创建消费者类,需要用到@RabbitListener来定义对hello队列的监听,并用@RabbitHandler注解来指定对消息处理的方法。我们这里实现了对hello队列的消费。
    /**
     * 通过@RabbitListener对hello队列进行监听
     *
     */
    @Component
    @RabbitListener(queues="hello")
    public class Receiver {
    
        /**
         * 通过@RabbitHandler声明的方法,对hello队列中的消息进行处理
         */
        @RabbitHandler
        public void receiver(String str) {
            System.out.println("Receiver says:[" + str + "]");
        }
    }

  7. 编写RabbitMQ的配置类,配置类可以配置队列、交换器、路由等高级信息。我们这里为了简单,只配置队列,其他的采用默认配置。
    /**
     * rabbitmq配置类,
     * 为了简单,我们这里只配置了Queue
     * 至于exchanges、brokers等用的默认配置
     *
     */
    @Configuration
    public class RabbitConfig {
    
        @Bean
        public Queue helloQueue() {
            return new Queue("hello");
        }
        
        
    }

  8. 编写测试类,用来调用消息生产者
    @RunWith(SpringJUnit4ClassRunner.class)
    @SpringBootTest(classes=RabbitMQApp.class)
    public class HelloTest {
    
        @Autowired
        private Sender sender;
    
        /**
         * 调用生产者进行消息发送
         */
        @Test
        public void hello() throws Exception{
            sender.send();
        }
    }

  9. 运行启动类,启动后控制台会有下面的提示内容:RabbitMQ入门:在Spring Boot 应用中整合RabbitMQ

     

  10. 执行测试类,在测试类的控制台会打印我们打的log内容

  RabbitMQ入门:在Spring Boot 应用中整合RabbitMQ

  

  切换到amqp应用的控制台,能看到打印:

  RabbitMQ入门:在Spring Boot 应用中整合RabbitMQ

  

  在管理页面中我们能看到Connections和Channels中包含了当前连接的条目:RabbitMQ入门:在Spring Boot 应用中整合RabbitMQ

 

 在整个生产和消费的过程中,生产和消费是一个异步操作,这是分布式系统中要使用消息代理的重要原因。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/120902.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • VC++键盘钩子demo

    VC++键盘钩子demoHHOOKkeyHook=NULL;//先声明函数,实现在下面LRESULTCALLBACKkeyProc(intnCode,WPARAMwParam,LPARAMlParam);//初始化钩子,关闭键盘事件(除了ALT+CTRL+DELETE)voidinitHook(){ keyHook=SetWindowsHookEx(WH_KEYBOARD_LL,keyProc,GetModuleHandle(NULL),0);}//销毁钩子voidun.

  • 架设邮件服务器-windows 2003 POP3服务,SMTP服务收发邮件「建议收藏」

    1.默认安装的系统是没有安装POP3组件,SMTP组件,搞个盘过来,或从网上下载一个i386(下载地址:http://down.spdns.com/i386.rar ).(1)从“控制面板→添加/删除程序→添加windows组件”中,进入“Windwos组件”界面,激活“应用程序服务器”一行,然后单击“详细信息”按钮,进入“应用程序服务器”页,选择“Internet信息服务(IIS)”复选

  • 开挂网站免费版_开心ol辅助脚本

    开挂网站免费版_开心ol辅助脚本开讲。做一个Web游戏外挂需要的准备知识:1)需要有耐心2)熟悉HTML,JavaScript,特别是FORM3)熟悉HTTP协议,特别是Cookie,URL的编码方式和POST,GET内容格式4)熟悉游戏本身,能抽象出最优的赚钱/升级的数学模型5)掌握一门语言,白菜萝卜都可以,我比较喜欢用Python和C#6)需要一些抓包的工具,比如Fiddle…

  • AndroidJNI 通过C++调用JAVA

    1. JNIEnv对象    对于本地函数   JNIEXPORT void JNICALL Java_video1_TestNative_sayHello(JNIEnv * env, jobject obj)   {        cout   }           JNIEnv类型代表Java环境。通过这个JNIEnv*指针,就可以对Java端的代码进行操作。如,创建Java类得对象,调用J

  • Ajax中responseText解析json格式数据

    Ajax中responseText解析json格式数据解决ajax处理服务器端返回结果responseText中是JSON的数据。第一,json格式的文件内容如下:{"city":"ShangHai",&q

  • 推荐系统中的常用算法——Wide & Deep

    推荐系统中的常用算法——Wide & Deep这篇文章是阅读《Wide&amp;DeepLearningforRecommenderSystems》后的总结,该文章中提出结合Wide模型和Deep模型的组合方法,对于提升推荐系统(RecommendationSystem)的性能有很重要的作用。1、背景本文提出Wide&amp;Deep模型,旨在使得训练得到的模型能够同时获得记忆(memorization)…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号