spring集成rabbitmq

(本文不是讲解的简单demo 而说的是一个web项目中的操作)

准备工作:

1:

:
jar(我是通过maven引入的)
因为我的项目使用的是spring 4.3版本的 所以引入的spring-rabbit 为1.6.6

<groupId>org.springframework.amqp</groupId>
<artifactId>spring-rabbit</artifactId>
<version>1.6.6.RELEASE</version>
<exclusions>
<exclusion>
<groupId>org.springframework</groupId>
<artifactId>spring-messaging</artifactId>
</exclusion>
</exclusions>
</dependency>

我这里是因为这个messaging这个jar跟我项目的有冲突，我选择不引入

2:

xml文件：（spring-rabbitmq.xml）

我这里使用的是direct模式 1对1

<!--连接工厂-->
<rabbit:connection-factory id="connectionFactory" host="localhost" port="5672" username="guest" password="guest"/>

<!-- 操作的模板-->
<rabbit:template id="rmqTemplate" exchange="chatRoomExchange"
connection-factory="connectionFactory"
message-converter="messageConverter"></rabbit:template>

<!-- RabbitAdmin 用于管理exchange，queue -->
<rabbit:admin id="rabbitAdmin" connection-factory="connectionFactory"/>

<!-- 声明一个队列 -->
<rabbit:queue name="ChatRoomMsgSendQue" id="ChatRoomMsgSendQue"></rabbit:queue>

<!--消息发送过来的时候    消息处理事件与交换路由绑定  durable:是否持久化  exclusive: 仅创建者可以使用的私有队列，断开后自动删除    auto_delete: 当所有消费客户端连接断开后，是否自动删除队列-->
<rabbit:direct-exchange name="chatRoomExchange" durable="true" auto-delete="false" id="chatRoomExchange">
<rabbit:bindings>

<rabbit:binding queue="ChatRoomMsgSendQue" key="ChatRoomMsgSendQueKey"/>

</rabbit:bindings>
</rabbit:direct-exchange>
<!--消息处理的时候，  队列和事件绑定-->
<bean id="producer"     class="cn.zfgc.jfinal.rabbitMqProducer.RmqProducer">
<property name="rmqTemplate" ref="rmqTemplate" />
</bean>
<!-- 消息转换器  -->
<!-- 创建消息转换器为SimpleMessageConverter -->
<bean id="messageConverter" class="org.springframework.amqp.support.converter.SimpleMessageConverter"></bean>

<bean id="ChatRoomMsgSendQueConsumer" class="这是包名.rabbitMqConsumer.ChatRoomMsgSendQueConsumer"/>

<!-- listener 容器 可以绑定多个消费者，一个消费者可以绑定多个queue  queues：监听的队列，多个的话用逗号（,）分隔  ref：监听器 -->
<rabbit:listener-container connection-factory="connectionFactory"
message-converter="messageConverter">

<rabbit:listener ref="ChatRoomMsgSendQueConsumer" queues="ChatRoomMsgSendQue"/>

</rabbit:listener-container>

3:

一个发送者，一个接收者

在service层注入 producer 发送模板

@Service
public class MsgSendService {
@Autowired
private RmqProducer producer;

public  void msgIntoMq(String routeKey, ChatMessage chatMessage, RmqProducer producer) {
//这个chatMessage是我需要发送到mq的对象
//这个可以是String 也可以是obj    mq的发送需要序列化 如果是对象 则需要impl  Serializable
//一个发送者对应一个消费者  之间通过 QueueKey 队列key来关联
RabbitMqMsgDO rabbitMqMsgDO = new RabbitMqMsgDO();
rabbitMqMsgDO.setParam(new Message(SerializationUtils.serialize(chatMessage), new MessageProperties()));
rabbitMqMsgDO.setRouteKey(routeKey);
producer.sendMsgToMq(rabbitMqMsgDO);
}
}

消费者端

public class ChatRoomMsgSendQueConsumer implements ChannelAwareMessageListener {
@Override
public void onMessage(Message message, Channel channel) throws Exception {

byte[] bytes = message.getBody();
ChatMessage chatMessage =
ae53
(ChatMessage) SerializationUtils.deserialize(bytes);
// 给服务端手动返回ack 确认
//不返回可能会造成消息锁死
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
//到这里我们发送的chatMessage已经接受完了
}
}
}