Spring---rabbitmq生产者配置

这篇文章是Spring整合Rabbitmq的其中针对生产者的一个简单的配置。如何来实现java向rabbitmq中发送消息

作为一个生产者，我们要配置哪些东西，我认为生产者需要配置的有几个必要的：

<?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"><!-- spring amqp默认的是jackson 的一个插件,目的将生产者生产的数据转换为json存入消息队列，由于Gson的速度快于jackson,这里替换为Gson的一个实现 --><bean id="jsonMessageConverter"class="org.springframework.amqp.support.converter.Jackson2JsonMessageConverter"></bean><!-- 连接服务配置 --><rabbit:connection-factory id="connectionFactory"host="127.0.0.1" username="guest" password="guest" port="5672"virtual-host="/" /><rabbit:admin connection-factory="connectionFactory" /><!-- spring template声明 --><rabbit:template id="amqpTemplate" connection-factory="connectionFactory"  exchange="wdgexchange" message-converter="jsonMessageConverter"  routing-key="*"  /><!-- queue 队列声明 --><rabbit:queue durable="true" auto-delete="false" exclusive="false" name="wdgqueue" /><!-- exchange queue binging key 绑定 --><!-- rabbitmq交换器 --><rabbit:direct-exchange name="wdgexchange" id="wdgexchange"durable="true" auto-delete="false"><rabbit:bindings><rabbit:binding queue="wdgqueue" key="*" /></rabbit:bindings></rabbit:direct-exchange></beans>

1.jsonMessageCoverter这个bean的配置。

2.链接包括密码，用户名，和主机ip地址，端口号，以及虚拟的virtual-host

3.链接工厂

4.声明模板，模板的声明里面需要有exchange，route-key ，id，connectFactory，message-converter，

5.声明队列

6.交换器

上面是rabbitmq-producer.xml的配置，我们应该如何实现消息的发送:

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

运行程序就可以实现消息的发送:

希望上面rabbitmq生产者的配置对你有所帮助，如果感觉确实有帮助了，可以扫描一下红包哦

Spring---rabbitmq生产者配置相关推荐

spring amqp rabbitmq fanout配置
基于spring amqp rabbitmq fanout配置如下: 发布端 <rabbit:connection-factory id="rabbitConnectionFactor ...
Spring Cloud Stream与RabbitMQ 生产者和消费者位于同一个应用服务
第一种模型:交换机类型为topic,路由key为"#",这是简单的使用模型当前Spring Cloud Rabbit的版本为2.1.2 <dependency>< ...
Spring Cloud Stream多RabbitMQ实例配置时报错no default binder has been set
当前Spring Cloud Rabbit的版本为2.1.2 <dependency><groupId>org.springframework.cloud</groupI ...
RabbitMq(八) SpringBoot整合RabbitMQ 生产者代码实现
在本章中我们将创建RabbitMQ的生产者工程,并实现生产者端代码实现. springboot整合RabbitMQ生产者工程步骤如下: 创建maven工程引入springboot及RabbitMQ依 ...
Go 学习笔记（57）— Go 第三方库之 amqp （RabbitMQ 生产者、消费者整个流程）
1. 安装 rabbitmq 的 golang 包 golang 可使用库 github.com/streadway/amqp 操作 rabbitmq .使用下面命令安装 RabbitMQ . go ...
Spring rabbitmq消息机制--手动确认
首先我们在Spring.xml中配置相关的消费者在配置的时候可以指定是手动确认还是自动的确认,比如: <rabbit:queue id=" ...
spring boot pom配置_125 SpringCloud服务配置中心
1. 为什么需要使用配置中心 (1) 常用的配置管理解决方案有哪些缺点? 硬编码:需要修改代码的话繁琐且风险大: 配置写在properties里面,在集群环境下,需要替换和重启: 写在xml文件中,一 ...
rabbitmq常用配置
属性配置关联的属性类 RabbitProperties spring:rabbitmq: # 地址host: 114.67.224.231 # 用户名username: guest # 密码pass ...
rabbitmq配置文件字段spring.rabbitmq.publisher-confirms过时
spring.rabbitmq.publisher-confirms过时解决在properties文件中确认消息报红因为源码中过时配置级别设置了Error 新版本jar包配置换了就可以了 spri ...

Spring---rabbitmq生产者配置

Spring---rabbitmq生产者配置相关推荐

最新文章

热门文章