經(jīng)典word整理文檔，僅參考，轉(zhuǎn)Word此處可刪除頁眉頁腳。本資料屬于網(wǎng)絡(luò)整理，如有侵權(quán)，請(qǐng)聯(lián)系刪除，謝謝！版本編審寫：核：批準(zhǔn)：文檔修改記錄在pom.xml中加入rabbitmq和springrabbitmq依賴包。<>com.rabbitmq</><artifactId>amqp-client</artifactId><version>3.5.4</version></dependency><dependency><>org.springframework.amqp</groupId><artifactId>spring-rabbitartifactId><version>1.4.5.RELEASE</version></dependency>使用官方的JavaAPI（amqp-client-3.5.4.jar）來直接連接RabbitMQ集群。2.1RabbitMQ發(fā)送直接連接RabbitMQ集群，然后發(fā)送消息。{,,===i=i{,,,}}}2.2RabbitMQ接收直接連接RabbitMQ集群，然后接收消息，注意需要手動(dòng)打開應(yīng)答機(jī)制，并手動(dòng)提交確認(rèn)消息，保證公平調(diào)度和消息持久化。=;){={,,===,,==}}使用xml配置，采用amqp-client-3.5.4.jar、spring-rabbit-1.4.5.RELEASE.jar和spring-amqp-1.4.5.RELEASE.jar手動(dòng)配置bean，然后采用Spring加載xml文件連接RabbitMQ集群，從而發(fā)送和接收消息。3.1RabbitMQ生產(chǎn)者RabbitMQ生產(chǎn)者的xml配置文件如下。=>>>>p>>>>=>>>>>>3.2RabbitMQ消費(fèi)者RabbitMQ生產(chǎn)者的xml配置文件如下。<?xmlversion"1.0"encoding"UTF-8"?><beansxmlns="/schema/beans"xmlns:xsi"/2001/XMLSchema-instance"xmlns:context"/schema/context"xsi:schemaLocation"/schema/beans/schema/beans/spring-beans-3.0.xsd/schema/context/schema/context/spring-context-3.0.xsd>value="storm_virtualhost"></property></bean><!--spring托管的rabbitmq連接工廠類--><beanid"cachingConnectionFactory"class="org.springframework.amqp.rabbit.connection.CachingConnectionFactory">value="6:5672,7:5672,8:5672"></property></bean><!--聲明消息轉(zhuǎn)換器SimpleMessageConverter--><beanid"messageConverter"class="org.springframework.amqp.support.converter.SimpleMessageConverter"></bean><!--用于消息的監(jiān)聽的代理類MessageListenerAdapter--><beanid"queueListenerAdapter"class="org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter"><constructor-argref="queueOneListenerHandler"/><propertyname"defaultListenerMethod"value="onMessage"></property><!--消息轉(zhuǎn)換器--><propertyname"messageConverter"ref"messageConverter"></property></bean><!--消息監(jiān)聽容器SimpleMessageListenerContainer--><beanid"listenerContainer"class="org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer"><!--消息隊(duì)列名稱--><propertyname"queueNames"value"storm_up_queue"></property><propertyname"connectionFactory"ref"cachingConnectionFactory"></property><propertyname"messageListener"ref"queueListenerAdapter"></property><!--設(shè)置固定的線程數(shù)--><propertyname"concurrentConsumers