简单Rabbitmq 发送消息和接收消息

1 先在Rabbitmq配置文件中预先创建好交换器，队列，路由等信息。

2 创建生产者发送消息

  @Autowiredprivate RabbitTemplate rabbitTemplate;private void mqSendMessage(UserOperLog userOperLog) throws Exception{rabbitTemplate.setExchange("test.file.exchange");rabbitTemplate.setRoutingKey("test.file.routing.key");//string 类型System.out.println("发送消息成功--"+JSONObject.toJSON(userOperLog).toString());rabbitTemplate.convertAndSend(JSONObject.toJSON(userOperLog).toString());}

先发送消息，举例场景是在用户操作后，将用户操作日志信息发送到队列中

打印信息：

发送消息成功--{"method":"","operation":"新增用户-rabbitmq","username":"admin"}

在rabbitmq后台管理界面进行查看，找到队列中的小内容，

查看消息内容，和我插入的信息一致

3 创建监听器，

@Component
@Slf4j
public class FileMqListener {//指定要监听的队列 ，消费实例@RabbitListener(queues = {"test.file.queue"},containerFactory = "singleListenerContainer")public void consumeMsg(@Payload String msg) {try {System.out.println("监听到消息--"+msg);} catch (Exception e) {e.printStackTrace();}}}

单一消费者实例，就是一个消费者进行消费

@Bean(name = "singleListenerContainer")public SimpleRabbitListenerContainerFactory listenerContainer(){SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();factory.setConnectionFactory(connectionFactory);factory.setMessageConverter(new Jackson2JsonMessageConverter());factory.setConcurrentConsumers(1);factory.setMaxConcurrentConsumers(1);factory.setPrefetchCount(1);return factory;}

@RabbitListener 监听queue中是否有需要被消费的信息，

打印信息如下：

test.file.queue--监听到消息--{"method":"","operation":"新增用户-rabbitmq","username":"admin"}

4 测试在rabbitmq后台管理界面发布消息

打印信息：

test.file.queue--监听到消息--rabbitmq后台手动发布消息

然后就可以开始了。

简单Rabbitmq 发送消息和接收消息相关推荐

【Java从0到架构师】RocketMQ 使用 - 发送消息、接收消息、特殊消息
RocketMQ 消息中间件入门案例 NameServer 地址发送消息同步发送消息异步发送消息一次性发送消息生产者组.消息封装接收消息消费方式:推式消费.拉式消费消息方式:集群模式 ...
企业微信接收消息服务器,接收消息与事件
[TOC] 关于接收消息为了能够让自建应用和企业微信进行双向通信,企业可以在应用的管理后台开启接收消息模式. 开启接收消息模式的企业,需要提供可用的接收消息服务器URL. 开启接收消息模式后,用户在 ...
C# 企业微信：开启消息接受接收消息推送消息
前言:微信吧!接触的人都会100%各种踩坑,就算同样东西去年做过,今年来一样踩坑,因为太多你稍微不记得一点点的细节就能让你研究N久.为此,我要把这个过程详细的记录下来. 一.开启消息接受 1.拿到企业 ...
RabbitMQ与SpringMVC集成并实现发送消息和接收消息（持久化）方案一
RabbitMQ是用于应用程序之间或者程序的不同组件之间的消息通信,进行了异步处理,而这种异步处理的方式大大的节省了服务器的请求响应时间,从而提高了系统的吞吐量,也就是生产-消费模型,一端往消息队列中 ...
浅析 postMessage 方法介绍、如何接收数据（监听message事件及其属性介绍）、使用postMessage的安全注意事项、具体使用方式（父子页面如何互发消息、接收消息）
postMessage 是 html5 引入的API,postMessage()方法允许来自不同源的脚本采用异步方式进行有效的通信,可以实现跨文本文档.多窗口.跨域消息传递,多用于窗口间数据通信,这也 ...
ActiveMQ 发送和接收消息
一.添加 jar 包 <dependency><groupId>org.apache.activemq</groupId><artifactId>act ...
Netty:实现同步发送并接收消息的一种方式
Netty创建通信服务时使用Nio异步通信, 配置代码(bootstrap.channel(NioSocketChannel.class);),要怎样实现这样一个同步发送消息并接收消息功能,虽然这样做 ...
RabbitMQ 基本消息模型和消息确认机制
01 前言关于 RabbitMQ 服务器的安装,本章节不做介绍,请培养个人动手能力,自行百度解决.RabbitMQ 成功安装后(win 版),浏览器输入:localhost:15672,则可以进入 ...
#rabbitMQ #重复消费 #可靠投递 #延时投递 #rabbitMQ交换机类型#重复消费#消息积压#消息丢失
exchange类型: 1, direct 指定direct后, 消息会根据你设置的routeing key(路由键), 发送到对应的队列中 1,新建direct交换机 2,添加队列, 并且绑定路由键 ...

简单Rabbitmq 发送消息和接收消息

简单Rabbitmq 发送消息和接收消息

简单Rabbitmq 发送消息和接收消息相关推荐

最新文章

热门文章