RabbitMQ学习之基于spring-rabbitmq的消息异步发送

spring-rabbitmq的源码到http://github.com/momania/spring-rabbitmq下载，并可以下载实例代码。由于我使用的rabbitmq版本是3.0.4，部分代码做了调整。

具体实例如下（创建自动删除非持久队列）：

1.资源配置application.properties

[plain] view plaincopy print?

#============== rabbitmq config ====================
rabbit.hosts=192.168.36.102
rabbit.username=admin
rabbit.password=admin
rabbit.virtualHost=/
rabbit.exchange=spring-queue-async
rabbit.queue=spring-queue-async
rabbit.routingKey=spring-queue-async

2..发送端配置applicationContext-rabbitmq-async-send.xml

[html] view plaincopy print?

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd">
<context:property-placeholder location="classpath:application.properties"/>
<bean id="rabbitConnectionFactory" class="com.rabbitmq.spring.connection.RabbitConnectionFactory">
<property name="connectionFactory">
<bean class="com.rabbitmq.client.ConnectionFactory">
<property name="username" value="${rabbit.username}"/>
<property name="password" value="${rabbit.password}"/>
<property name="virtualHost" value="${rabbit.virtualHost}"/>
</bean>
</property>
<property name="hosts" value="${rabbit.hosts}"/>
</bean>
<bean id="rabbitChannelFactory" class="com.rabbitmq.spring.channel.RabbitChannelFactory">
<property name="connectionFactory" ref="rabbitConnectionFactory"/>
</bean>
<bean id="rabbitTemplate" class="com.rabbitmq.spring.template.ASyncRabbitTemplate">
<property name="channelFactory" ref="rabbitChannelFactory"/>
<property name="exchange" value="${rabbit.exchange}"/>
<property name="routingKey" value="${rabbit.routingKey}"/>
<property name="exchangeType" value="TOPIC"/>
<property name="mandatory" value="false"/>
<property name="immediate" value="false"/>
</bean>
</beans>

3.接收端配置applicationContext-rabbitmq-async-receive.xml

[html] view plaincopy print?

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd">
<context:property-placeholder location="classpath:application.properties"/>
<bean id="rabbitConnectionFactory" class="com.rabbitmq.spring.connection.RabbitConnectionFactory">
<property name="connectionFactory">
<bean class="com.rabbitmq.client.ConnectionFactory">
<property name="username" value="${rabbit.username}"/>
<property name="password" value="${rabbit.password}"/>
<property name="virtualHost" value="${rabbit.virtualHost}"/>
</bean>
</property>
<property name="hosts" value="${rabbit.hosts}"/>
</bean>
<bean id="rabbitChannelFactory" class="com.rabbitmq.spring.channel.RabbitChannelFactory">
<property name="connectionFactory" ref="rabbitConnectionFactory"/>
</bean>
<bean id="receiveMsgHandler" class="cn.slimsmart.rabbitmq.spring.rabbitmq.demo.async.ReceiveMsgHandler"/>
<bean id="quotingParamtersTopicAdapter" class="com.rabbitmq.spring.listener.RabbitMessageListenerAdapter">
<property name="channelFactory" ref="rabbitChannelFactory"/>
<property name="delegate" ref="receiveMsgHandler"/>
<property name="listenerMethod" value="handleMessage"/>
<property name="exchange" value="${rabbit.exchange}"/>
<property name="exchangeType" value="TOPIC"/>
<property name="routingKey" value="${rabbit.routingKey}"/>
<property name="queueName" value="${rabbit.queue}"/>
<property name="poolsize" value="5"/>
</bean>
</beans>

4.消息处理服务ReceiveMsgHandler.Java

[java] view plaincopy print?

package cn.slimsmart.rabbitmq.spring.rabbitmq.demo.async;
public class ReceiveMsgHandler {
public void handleMessage(String text) {
System.out.println("Received: " + text);
}
}

5.发送端启动代码Send.java

[java] view plaincopy print?

package cn.slimsmart.rabbitmq.spring.rabbitmq.demo.async;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.rabbitmq.spring.template.ASyncRabbitTemplate;
public class Send {
public static void main(String[] args) throws InterruptedException {
ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext-rabbitmq-async-send.xml");
ASyncRabbitTemplate amqpTemplate = context.getBean(ASyncRabbitTemplate.class);
for(int i=0;i<10000;i++){
amqpTemplate.send("test spring async=>"+i);
Thread.sleep(100);
}
}
}

6.接收端启动代码Send.java

[java] view plaincopy print?

package cn.slimsmart.rabbitmq.spring.rabbitmq.demo.async;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Receive {
public static void main(String[] args) {
new ClassPathXmlApplicationContext("applicationContext-rabbitmq-async-receive.xml");
}
}

先启动接收端，再启动发送端。接收到消息如下：

[plain] view plaincopy print?

Received: test spring async=>0
Received: test spring async=>1
Received: test spring async=>2
Received: test spring async=>3
Received: test spring async=>4
Received: test spring async=>5
Received: test spring async=>6
Received: test spring async=>7
......

实例代码：http://download.csdn.net/detail/tianwei7518/8135637

转载于:https://www.cnblogs.com/telwanggs/p/7124785.html

RabbitMQ学习之基于spring-rabbitmq的消息异步发送相关推荐

乐行学院RabbitMQ学习教程第一章 RabbitMQ介绍(可供技术选型时使用)
乐行学院RabbitMQ学习教程第一章 RabbitMQ介绍 RabbitMQ介绍 1.RabbitMQ技术简介 2.RabbitMQ其他扩展插件 2.1监控工具rabbitmq-managemen ...
RabbitMQ学习笔记四：RabbitMQ命令（附疑难问题解决）
RabbitMQ学习笔记四:RabbitMQ命令(附疑难问题解决) 参考文章: (1)RabbitMQ学习笔记四:RabbitMQ命令(附疑难问题解决) (2)https://www.cnblogs. ...
魔方APP项目-06-用户注册，完成短信验证码的校验、基于Celery实现短信异步发送、用户登录，jwt登陆认证、服务端提供用户登录的API接口
一.用户注册- 1.完成短信验证码的校验 application.utils.language.message,代码: class ErrorMessage():ok = "ok" ...
RabbitMQ学习之基于spring-rabbitmq的RPC远程调用
http://blog.csdn.net/zhu_tianwei/article/details/40920985 spring-rabbitmq中实现远程接口调用,主要在com.rabbitmq.s ...
RabbitMQ 学习（九）-- RabbitMQ 集群
RabbitMQ 集群最开始我们介绍了如何安装及运行 RabbitMQ 服务,不过这些是单机版的,无法满足目前真实应用的要求.如果 RabbitMQ 服务器遇到内存崩溃.机器掉电或者主板故障等情况, ...
spring.rabbitmq.template.mandatory 和spring.rabbitmq.publisher-returns
在SpringBoot的RabbitMQ配置中,有如下一项: spring.rabbitmq.template.mandatory = true 官方注释: Enable mandatory mess ...
RabbitMq学习笔记005---登录rabbitmq报错User can only log in via localhost
在访问管理界面使用guest用户登录时出现login failed错误. 到服务器上查询日志显示出现错误的原因是:HTTP access denied: user 'guest' - User can ...
如何在优雅地Spring 中实现消息的发送和消费
本文将对rocktmq-spring-boot的设计实现做一个简单的介绍,读者可以通过本文了解将RocketMQ Client端集成为spring-boot-starter框架的开发细节,然后通过一个 ...
如何在优雅地Spring 中实现消息的发送和消费 1
本文将对rocktmq-spring-boot的设计实现做一个简单的介绍,读者可以通过本文了解将RocketMQ Client端集成为spring-boot-starter框架的开发细节,然后通过一个 ...

RabbitMQ学习之基于spring-rabbitmq的消息异步发送

RabbitMQ学习之基于spring-rabbitmq的消息异步发送相关推荐

最新文章

热门文章