SpringBoot的RabbitMQ消息队列: 一、消息发送接收第一印象

本文主要是介绍SpringBoot的RabbitMQ消息队列: 一、消息发送接收第一印象，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1.在原来项目的基础上.

修改pom.xml配置,导入jar包

增加配置

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

修改系统配置文件application.properties，编制RabbitMQ的链接参数

spring.application.name=rabbitmq-hello
spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=123456

ps:这里特别注意,mq的账号和密码都正常,还提示连接不上,这个时候就需要注意改账号的权限问题.

在打开localhost:15672 使用上述配置的账号密码登陆,进入admin选项卡,查看是否有权限,

Can access virtual hosts

看这个是否有赋予对应的权限.....没有则需要加上,不然是访问不到的.

编制RabbitMQ配置、发送、接受的代码

1、编写配置文件类

在com.example包中增加类，名称为HelloRabbitConfig，并修改代码为

[java]  view plain copy  
 package com.example;  
   
 import org.springframework.amqp.core.Queue;  
 import org.springframework.context.annotation.Bean;  
 import org.springframework.context.annotation.Configuration;  
   
 @Configuration  
 public class HelloRabbitConfig {  
   
     @Bean  
     public Queue helloQueue() {  
         return new Queue("hello");  
     }  
 }  

2、编写发送消息类

在com.example包中增加类，名称为HelloSender，并修改代码为

[java]  view plain copy  
 package com.example;  
   
 import java.util.Date;  
   
 import org.slf4j.Logger;  
 import org.slf4j.LoggerFactory;  
 import org.springframework.amqp.core.AmqpTemplate;  
 import org.springframework.beans.factory.annotation.Autowired;  
 import org.springframework.stereotype.Component;  
   
 @Component  
 public class HelloSender {  
   
     protected static Logger logger=LoggerFactory.getLogger(HelloSender.class);   
       
     @Autowired  
     private AmqpTemplate rabbitTemplate;  
   
     public String send(String name) {  
         String context = "hello "+name+" --" + new Date();  
         logger.debug("HelloSender: " + context);  
         this.rabbitTemplate.convertAndSend("hello", context);  
         return context;  
     }  
 }  

3、编写接受消息类

在com.example包中增加类，名称为HelloReceiver，并修改代码为

[html]  view plain copy  
 package com.example;  
   
 import org.slf4j.Logger;  
 import org.slf4j.LoggerFactory;  
 import org.springframework.amqp.rabbit.annotation.RabbitHandler;  
 import org.springframework.amqp.rabbit.annotation.RabbitListener;  
 import org.springframework.stereotype.Component;  
   
 @Component  
 @RabbitListener(queues = "hello")  
 public class HelloReceiver {  
     protected static Logger logger = LoggerFactory.getLogger(HelloReceiver.class);  
   
     @RabbitHandler  
     public void process(String hello) {  
         logger.debug("HelloReceiver : " + hello);  
     }  
 }  

4、编写RestController，调用发送消息

在com.example包中增加类，名称为HelloController，并修改代码为

[java]  view plain copy  
 package com.example;  
   
 import org.slf4j.Logger;  
 import org.slf4j.LoggerFactory;  
 import org.springframework.beans.factory.annotation.Autowired;  
 import org.springframework.web.bind.annotation.PathVariable;  
 import org.springframework.web.bind.annotation.RequestMapping;  
 import org.springframework.web.bind.annotation.RestController;  
   
 @RestController   
 public class HelloController {  
     protected static Logger logger=LoggerFactory.getLogger(HelloController.class);   
       
     @Autowired  
         private HelloSender helloSender;  
       
     @RequestMapping("/send/{name}")  
     public String helloworld(@PathVariable String name) {  
         return helloSender.send(name);  
     }  
 }  

5、运行测试

A、启动Docker中容器rabbitmq5672。docker start rabbitmq5672 (如果已启动，则忽略)

B、启动工程。在工程所在的文件夹打开命令行，且在命令行中执行 mvn spring-boot:run

C、在浏览器中输入 http://localhost：8080/send/上帝

浏览器中显示

控制台中显示，成功发送、接收消息

三、小结

1、rabbitmq连接

1.1 springboot,在启动时，根据系统配置文件的参数建立一个rabbitmq连接。参看控制台日志：

(MBeanExporter.java:431)- Registering beans for JMX exposure on startup

(MBeanExporter.java:916)- Bean with name 'rabbitConnectionFactory' has been autodetected for JMX exposure

(MBeanExporter.java:678)- Located managed bean 'rabbitConnectionFactory': registering with JMX server as MBean [org.springframework.amqp.rabbit.connection:name=rabbitConnectionFactory,type=CachingConnectionFactory]

(DefaultLifecycleProcessor.java:343)- Starting beans in phase -2147482648

(DefaultLifecycleProcessor.java:343)- Starting beans in phase 2147483647

(AbstractConnectionFactory.java:347)- Created new connection: SimpleConnection@7075a8f1 [delegate=amqp://test@127.0.0.1:5672/, localPort= 62881]

1.2、在springboot启动之后，查看rabbitmq(http://localhost:15672/)的connections，也可以查看到。当然，你也可以停止springboot去看链接(停止之后，当然就没有链接了).
1.3、把logbak.xml的root的等级修改为debug，你会发现监听在不断的链接reabitmq；它就是一个心跳。通过这个心跳，rabbitmq也知道存在哪些监听器在监听那个队列。

2、配置文件

在配置文件中，仅仅配置了一个名为hello的队列。以后发送、接收都与这个队列相关。

3、发送消息

3.1、发送消息使用模板机制，用springboot自动注入的rabbitTemplate，它已经封装好链接、管道、转换等。

3.2、消息转换和发送

void convertAndSend(String routingKey, Object message) throws AmqpException;

它的注释是：Convert a Java object to an Amqp {@link Message} and send it to a default exchange with a specific routing key.

转换一个Java对象为Amqp消息，然后再用缺省的交换机指定路由键发送消息。

4、接受消息

4.1、监听消息

在类上声明@RabbitListener(queues = "hello")，表示监听hello队列

4.2、消息处理句柄

在接收处理消息的方法上声明@RabbitHandler

Annotation that marks a method to be the target of a Rabbit message listener within a class that is annotated with {@link RabbitListener}.

5、印象

整个工程比较简单，没有什么特殊的配置，仅仅三个类文件即可实现消息的发送和接受。

这篇关于SpringBoot的RabbitMQ消息队列: 一、消息发送接收第一印象的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

SpringBoot的RabbitMQ消息队列: 一、消息发送接收第一印象

修改系统配置文件application.properties，编制RabbitMQ的链接参数

spring.application.name=rabbitmq-hello
spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=123456

编制RabbitMQ配置、发送、接受的代码

1、编写配置文件类

2、编写发送消息类

3、编写接受消息类

4、编写RestController，调用发送消息

5、运行测试

三、小结

1、rabbitmq连接

2、配置文件

3、发送消息

相关文章

java如何解压zip压缩包

SpringBoot中SM2公钥加密、私钥解密的实现示例详解

Spring WebFlux 与 WebClient 使用指南及最佳实践

Spring Boot @RestControllerAdvice全局异常处理最佳实践

Spring IoC 容器的使用详解(最新整理)

Spring事务传播机制最佳实践

怎样通过分析GC日志来定位Java进程的内存问题

Java进程异常故障定位及排查过程

java中新生代和老生代的关系说明

Java设计模式---迭代器模式(Iterator)解读

SpringBoot的RabbitMQ消息队列: 一、消息发送接收第一印象

修改系统配置文件application.properties，编制RabbitMQ的链接参数

spring.application.name=rabbitmq-hello spring.rabbitmq.host=127.0.0.1 spring.rabbitmq.port=5672 spring.rabbitmq.username=admin spring.rabbitmq.password=123456

编制RabbitMQ配置、发送、接受的代码

1、编写配置文件类

2、编写发送消息类

3、编写接受消息类

4、编写RestController，调用发送消息

5、运行测试

三、小结

1、rabbitmq连接

2、配置文件

3、发送消息

相关文章

spring.application.name=rabbitmq-hello
spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=123456