消息队列-----生成者 Spring整合rabbitmq

最近做Spring结合Rabbitmq，然后往队列里面发送了一个消息，如何查看消息

打开:http://127.0.0.1:15672

输入用户名和密码:找到你的队列

我们可以找到自己的队列，并且发现里面有一个消息，我们点击这个队列，进入:

可以看到这个队列的这些基本的信息，首先是overview:

Consumers:

当前队列没有消费者

GetMessages:

Publish Messages：

那么java；如何向消息队列中发送消息:

rabbitmq-producer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"xmlns:rabbit="http://www.springframework.org/schema/rabbit"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/rabbithttp://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd"><!-- 连接服务配置 --><rabbit:connection-factory id="connectionFactory"host="127.0.0.1" username="guest" password="guest" port="5672"virtual-host="/" channel-cache-size="5" /><rabbit:admin connection-factory="connectionFactory" /><!-- queue 队列声明 --><rabbit:queue  durable="true"auto-delete="false" exclusive="false" name="spring.queue.tag" /><!-- exchange queue binging key 绑定 --><rabbit:direct-exchange name="spring.queue.exchange"durable="true" auto-delete="false"><rabbit:bindings><rabbit:binding queue="spring.queue.tag" key="spring.queue.tag.key" /></rabbit:bindings></rabbit:direct-exchange><!-- spring amqp默认的是jackson 的一个插件,目的将生产者生产的数据转换为json存入消息队列，由于Gson的速度快于jackson,这里替换为Gson的一个实现 --><bean id="jsonMessageConverter"class="org.springframework.amqp.support.converter.Jackson2JsonMessageConverter"></bean><!-- spring template声明 --><rabbit:template id="amqpTemplate" exchange="spring.queue.exchange"  routing-key="spring.queue.tag.key"connection-factory="connectionFactory" message-converter="jsonMessageConverter" />
</beans>

:运行下面的程序:

 public static void main(String[] args) {ApplicationContext context = new ClassPathXmlApplicationContext("rabbitmq-producer.xml");AmqpTemplate amqpTemplate = context.getBean(RabbitTemplate.class);   amqpTemplate.convertAndSend("333");}

就可以往消息队列里面插入消息了

希望对你有所帮助

消息队列-----生成者 Spring整合rabbitmq相关推荐

RabbitMQ,RabbitMQ 的工作模式,Spring 整合 RabbitMQ,Springboot 整合RabbitMQ
什么是RabbitMQ 1.1 MQ概述 MQ全称 Message Queue(消息队列),是在消息的传输过程中保存消息的容器.多用于分布式系统之间进行通信. ⚫ MQ,消息队列,存储消息的中间件 ⚫ ...
RabbitMQ消息队列(六)：SpringBoot整合之通配符模式
RabbitMQ消息队列(六):SpringBoot整合之通配符模式 [外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-AeZQrNHS-1660220618697)(E: ...
Spring整合RabbitMQ(包含生产者和消费者)
生产者创建一个MAVEN项目spring-exchange-producer作为消息队列的生产者导入相关的依赖坐标 <dependencies><!-- https://mvnr ...
spring 整合 RabbitMQ 3.9.11
spring 整合 RabbitMQ 3.9.11 rabbitmq 3.9.11 创建工程不管用什么办法创建出一个空的工程出来,或者在已有工程里面创建一个新的module,下面只说创建新modul ...
消息队列，我只选RabbitMQ！
高并发架构是架构师的必修课,而消息队列,则是王冠上最闪亮的那颗明珠!能否驾驭消息队列这款高并发神器,亦成为架构师的试金石.作为专注.NET领域十多年的老架构师,下面从队列本质.技术选型.实战应用三个方 ...
高性能RabbitMQ消息队列介绍及 SpringBoot整合
一.高性能RabbitMQ RabbitMQ是一个由erlang开发的AMQP(Advanced Message Queue )的开源实现.AMQP 的出现其实也是应了广大人民群众的需求,虽然在同步消 ...
rabbitMQ教程 spring整合rabbitMQ代码实例
转载自 https://www.cnblogs.com/tohxyblog/p/7256554.html 一.开启rabbitMQ服务,导入MQ jar包和gson jar包(MQ默认的是jackso ...
消息队列技术介绍 : ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ、RocketMQ
一. 消息队列概述前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家.点击跳转到教程. 消息队列中间件是分布式系统中重要的组件,主要解决应用耦合.异步消息.流量削锋等问 ...
spring整合rabbitMQ最新版
文章目录一.简单对象 1. 依赖 2. 生产者 3. 消费者 4. 配置文件 5. spring版本二.复杂对象 2.1. 生产者 2.2. 消费者一.简单对象 1. 依赖 <!--spr ...

消息队列-----生成者 Spring整合rabbitmq

消息队列-----生成者 Spring整合rabbitmq相关推荐

最新文章

热门文章