文件编号:
版本号:V1.0 RabbitMQ集群使用说明
编写:
审核:
批准:
文档修改记录
1.Maven配置pom
在pom.xml中加入rabbitmq和spring rabbitmq依赖包。
2.使用Java API 直接连接RabbitMQ集群
使用官方的Java API(amqp-client-3.5.4.jar)来直接连接RabbitMQ集群。
2.1RabbitMQ发送
直接连接RabbitMQ集群,然后发送消息。
2.2RabbitMQ接收
直接连接RabbitMQ集群,然后接收消息,注意需要手动打开应答机制,并手动提交确认消息,保证公平调度和消息持久化。
3.使用Spring Xml托管连接RabbitMQ集群
使用xml配置,采用amqp-client-3.5.4.jar、spring-rabbit-1.4.5.RELEASE.jar 和spring-amqp-1.4.5.RELEASE.jar手动配置bean,然后采用Spring加载xml文件连接RabbitMQ集群,从而发送和接收消息。
3.1RabbitMQ生产者
RabbitMQ生产者的xml配置文件如下。
3.2RabbitMQ消费者
RabbitMQ生产者的xml配置文件如下。