Springboot接入RabbitMQ詳細教程

本文適用於對 rabbitmq 有所了解的人，在此不討論mq的原理，只討論如何接入。其實spring boot 整合 rabbitmq 非常簡單，本文章使用的是spring boot 提供了spring-boot-starter-amqp專案對訊息各種支援。

1.配置pom檔案所依賴的主要jar包

org.springframework.amqp

spring-rabbit
2.0.4.release

## rabbitmq

spring.rabbitmq.host=127.0.0.1spring.rabbitmq.port=5672spring.rabbitmq.username=root
spring.rabbitmq.password=root
spring.rabbitmq.virtual-host=/# rabbitmq訊息確認
spring.rabbitmq.publisher-confirms=true
spring.rabbitmq.publisher-returns=true
## rabbitmq-config
rabbitmq.exchange-key =rabbitmq.test.exchange
rabbitmq.routing-key =rabbitmq.test.routing.key
rabbitmq.queue-name=rabbitmq.queue.name.test

3.交換機和佇列繫結配置

@value("$")

string queuename;
@value("$")
string exchangekey;
@value("$")
string routingkey;
@bean(value = "$")
public
queue initordercancelqueue()
@bean(value = "$")
public
customexchange customexchange()
@bean
public binding binding(@qualifier(value = "$") queue queue,
@qualifier(value = "$") customexchange exchange)

4.生產者

@value("$")

string exchangekey;
@autowired
private
amqptemplate amqptemplate;
/*** 傳送mq
* @param
routingkey
* @param
obj 引數 */
public
void
sendnotification(string routingkey, object obj)

5消費者

@rabbithandler

@rabbitlistener(queues = "$")
public
void receiverabbitmqmsg(message msg, channel channel, @header(amqpheaders.delivery_tag) long
tag):{}",funcname,msg);
trycatch
(exception e) 
finally
}

6.測試

@autowired

rabbitmqproducer producer;
@value("$")
string routingkey;
public
void
sendmsg()
catch
(exception e)
}

搞定！就這麼簡單，趕快自己動手試試吧

SpringBoot使用訊息中介軟體RabbitMQ

首先在docker中安裝rabbitmq,pull 帶有web介面的 docker pull rabbitmq 3 management5672為客戶端,15672為web介面埠 docker run d p5672 5672 p15672 15672 name rabbitmq01 映象id簡要介...

R A B 大數問題

給定兩個整數a和b，其表示形式是 從個位開始，每三位數用逗號 隔開。現在請計算a b的結果，並以正常形式輸出。input 輸入包含多組資料資料，每組資料佔一行，由兩個整數a和b組成 10 9 a,b 10 9 output 請計算a b的結果，並以正常形式輸出，每組資料佔一行。sample inpu...

springboot接入elk日誌平台

elk是三個開源軟體的縮寫，分別表示 elasticsearch logstash,kibana 現在新增了乙個輕量級的日誌收集處理工具filebeat，filebeat占用資源少，適合於在各個伺服器上蒐集日誌後傳輸給logstash，官方也推薦此工具。springboot應用可以使用tcp連線將日...