发送者 spring配置文件

消息发送代码

package com.zhu.mq;import org.springframework.amqp.core.AmqpTemplate;import org.springframework.beans.factory.annotation.Autowired;public class RabbitMqSender {	@Autowired	private AmqpTemplate amqpTemplate;	@Autowired	private AmqpTemplate fanoutTemplate;	@Autowired	private AmqpTemplate rabbitTemplate;	/**	 * 点对点	 */	public void sendDataToCrQueue(Object obj) {		amqpTemplate.convertAndSend("queue_one_key", obj);	}	/**	 * 发送 发布--订阅消息	 */	public void sendFanoutMsg(Object obj) {		fanoutTemplate.convertAndSend(obj);	}	/**	 * 主题	 */	public void sendTopicMsg(String topic,Object obj) {		rabbitTemplate.convertAndSend(topic,obj);	}}

发送消息

RabbitMqSender sender = new RabbitMqSender();String str="test1";Object obj = (Object)str;sender.sendDataToCrQueue(obj);sender.sendFanoutMsg(obj);sender.sendTopicMsg("zhu.p1",obj);sender.sendTopicMsg("zhu.p2",obj);

接受者

spring配置文件

监听器代码 direct监听器

package com.zhu.mq;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.amqp.core.Message;import org.springframework.amqp.core.MessageListener;public class DirectListener implements MessageListener {	private static Logger logger = LoggerFactory.getLogger(DirectListener.class);	@Override	public void onMessage(Message message) {		logger.info("Direct queue data:" + new String(message.getBody()));	}}

fanout监听器

package com.zhu.mq;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.amqp.core.Message;import org.springframework.amqp.core.MessageListener;public class FanoutLitener implements MessageListener {	private static Logger logger = LoggerFactory.getLogger(FanoutLitener.class);	@Override	public void onMessage(Message message) {		logger.info("Fanout queue data:" + new String(message.getBody()));	}}

topic监听器

package com.zhu.mq;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.amqp.core.Message;import org.springframework.amqp.core.MessageListener;public class TopicLitener implements MessageListener {	private static Logger logger = LoggerFactory.getLogger(TopicLitener.class);	@Override	public void onMessage(Message message) {		logger.info("Topic queue data:" + new String(message.getBody()));	}}