您好,登錄后才能下訂單哦!
Spring web中怎么集成rabbitmq,針對(duì)這個(gè)問(wèn)題,這篇文章詳細(xì)介紹了相對(duì)應(yīng)的分析和解答,希望可以幫助更多想解決這個(gè)問(wèn)題的小伙伴找到更簡(jiǎn)單易行的方法。
引入java包:
本項(xiàng)目中僅引入了四個(gè)java包:amqp-client-5.7.3.jar,spring-rabbit-2.2.2.RELEASE.jar,spring-retry-1.2.4.RELEASE.jar,spring-amqp-2.2.2.RELEASE.jar
spring-rabbitmq.xml
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:rabbit="http://www.springframework.org/schema/rabbit" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit.xsd"> <!--配置connection-factory,指定連接rabbit server參數(shù) --> <rabbit:connection-factory id="connectionFactory" username="guest" password="guest" host="localhost" port="5672" /> <!--定義rabbit template用于數(shù)據(jù)的發(fā)送 --> <rabbit:template id="amqpTemplate" connection-factory="connectionFactory" exchange="exchangeTest" /> <!--通過(guò)指定下面的admin信息,當(dāng)前producer中的exchange和queue會(huì)在rabbitmq服務(wù)器上自動(dòng)生成 --> <rabbit:admin connection-factory="connectionFactory" /> <!--定義queue --> <rabbit:queue name="queueTest" durable="true" auto-delete="false" exclusive="false" /> <!-- 定義direct exchange,綁定queueTest --> <rabbit:direct-exchange name="exchangeTest" durable="true" auto-delete="false"> <rabbit:bindings> <rabbit:binding queue="queueTest" key="queueTestKey"></rabbit:binding> </rabbit:bindings> </rabbit:direct-exchange> <!-- 消息接收者 --> <bean id="messageReceiver" class="club.codeapes.web.core.rabbitmq.RabbitMqMessageConsumer"></bean> <!-- queue litener 觀察 監(jiān)聽(tīng)模式 當(dāng)有消息到達(dá)時(shí)會(huì)通知監(jiān)聽(tīng)在對(duì)應(yīng)的隊(duì)列上的監(jiān)聽(tīng)對(duì)象--> <rabbit:listener-container connection-factory="connectionFactory"> <rabbit:listener queues="queueTest" ref="messageReceiver"/> </rabbit:listener-container> </beans>
spring中需要引入這個(gè)xml, 主要在總spring.xml?;蛘遷eb.xml中需要引入下。
RabbitMqMessageConsumer
package club.codeapes.web.core.rabbitmq; import club.codeapes.common.date.DateUtil; import com.alibaba.fastjson.JSON; import org.springframework.amqp.core.Message; import org.springframework.amqp.core.MessageListener; public class RabbitMqMessageConsumer implements MessageListener { @Override public void onMessage(Message message) { System.out.println("消費(fèi)信息," + DateUtil.getNow("yyyy-MM-dd HH:mm:ss") + "---->" + message); } }
RabbitMqMessageProducer:
package club.codeapes.web.core.rabbitmq; import org.springframework.amqp.core.AmqpTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Repository; @Repository public class RabbitMqMessageProducer{ @Autowired private AmqpTemplate amqpTemplate; public void sendMessage(Object message) { System.out.println("to send message:" + message); amqpTemplate.convertAndSend("queueTestKey", message); } }
關(guān)于Spring web中怎么集成rabbitmq問(wèn)題的解答就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,如果你還有很多疑惑沒(méi)有解開(kāi),可以關(guān)注億速云行業(yè)資訊頻道了解更多相關(guān)知識(shí)。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。