RabbitMQ介紹
RabbitMQ是一個(gè)開源的AMQP實(shí)現(xiàn)，服務(wù)器端用Erlang語言編寫缭嫡，支持多種客戶端缔御，如：Python、Ruby妇蛀、.NET耕突、Java笤成、JMS、C眷茁、PHP炕泳、ActionScript、XMPP上祈、STOMP等培遵，支持AJAX。用于在分布式系統(tǒng)中存儲(chǔ)轉(zhuǎn)發(fā)消息雇逞，在易用性荤懂、擴(kuò)展性、高可用性等方面表現(xiàn)不俗塘砸。
關(guān)于AMQP(摘自互聯(lián)網(wǎng)):
AMQP节仿，即Advanced Message Queuing Protocol，高級(jí)消息隊(duì)列協(xié)議掉蔬，是應(yīng)用層協(xié)議的一個(gè)開放標(biāo)準(zhǔn)廊宪，為面向消息的中間件設(shè)計(jì)。消息中間件主要用于組件之間的解耦女轿，消息的發(fā)送者無需知道消息使用者的存在宛徊，反之亦然物蝙。 AMQP的主要特征是面向消息催享、隊(duì)列英岭、路由（包括點(diǎn)對(duì)點(diǎn)和發(fā)布/訂閱）、可靠性北救、安全荐操。
題外話：其實(shí)Redis也有提供隊(duì)列功能。但我覺得珍策，redis還是專門用在緩存方面吧托启。
SpringBoot集成RabbitMQ
0.老規(guī)矩，加入pom依賴攘宙，這已經(jīng)是Springboot的套路了屯耸。
org.springframework.bootspring-boot-starter-amqp
1.application.properties配置加入rabbitmq相關(guān)配置。
RabbitAutoConfiguration類是其自動(dòng)加載配置類蹭劈。
# rabbitmq相關(guān)配置spring.rabbitmq.host=127.0.0.1spring.rabbitmq.port=5672spring.rabbitmq.username=guestspring.rabbitmq.password=guest
2.關(guān)于配置疗绣，以上兩步就完成了(Springboot真的太方便了，寫代碼都是愉悅的)铺韧。正常使用時(shí)持痰，若作為一個(gè)消費(fèi)者，我們會(huì)配置一個(gè)接收隊(duì)列祟蚀，這里為了示例工窍，直接以最小配置來演示下。
配置一個(gè)名為okong的隊(duì)列
@ConfigurationpublicclassRabbitConfig{/**? ? * 定義一個(gè)名為：oKong 的隊(duì)列? ? *@return*/@BeanpublicQueueokongQueue(){returnnewQueue("okong");? ? }}
配置隊(duì)列處理類,這里的隊(duì)列就是上面配置的隊(duì)列名稱前酿。：
Consumer.java
@Component//@RabbitListener 監(jiān)聽 okong 隊(duì)列@RabbitListener(queues ="okong")@Slf4jpublicclassConsumer{/**? ? *@RabbitHandler指定消息的處理方法? ? *@parammessage? ? */@RabbitHandlerpublicvoidprocess(String message){? ? ? ? log.info("接收的消息為: {}", message);? ? }}
編寫消息發(fā)送類患雏，這里直接寫成api方法，方便調(diào)試罢维。
DemoController.java
/** * 簡(jiǎn)單示例 發(fā)送和接收隊(duì)列消息 *@authoroKong * */@RestControllerpublicclassDemoController{//AmqpTemplate接口定義了發(fā)送和接收消息的基本操作,目前spring官方也只集成了Rabbitmq一個(gè)消息隊(duì)列淹仑。。@AutowiredAmqpTemplate rabbitmqTemplate;@GetMapping("/send")publicStringsend(String msg){//發(fā)送消息rabbitmqTemplate.convertAndSend("okong", msg);return"消息："+ msg +",已發(fā)送";? ? }}
在此我向大家推薦一個(gè)架構(gòu)學(xué)習(xí)交流圈：830478757 ?幫助突破瓶頸 提升思維能力
3.啟動(dòng)應(yīng)用肺孵，正常配置成功匀借，在Rabbitmq的控制臺(tái)，是可以看見連接對(duì)象的平窘。說明已經(jīng)正常啟動(dòng)了吓肋。
4.訪問：http://127.0.0.1:8080/send?msg=hello,rabbitmq, 在控制臺(tái)就可以看見消費(fèi)者已經(jīng)消費(fèi)到此條消息了：
2018-07-2422:59:00.777INFO11424---[cTaskExecutor-1]c.l.l.springboot.chapter12.Consumer: 接收的消息為:hello,rabbitmq
控制臺(tái)界面，在Queues標(biāo)簽頁(yè)瑰艘，也可以查看到隊(duì)列okong的消息是鬼。
總結(jié)
本章節(jié)主要是對(duì)RabbitMQ的集成和簡(jiǎn)單使用進(jìn)行了說明，對(duì)于高并發(fā)系統(tǒng)而言紫新，消息隊(duì)列是一個(gè)常見的解決方案了均蜜。比如實(shí)現(xiàn)異步消息的通知，實(shí)現(xiàn)消費(fèi)者/生產(chǎn)者模式等芒率。由于對(duì)rabbitmq沒有過多的了解囤耳，詳細(xì)的用法及相關(guān)消息隊(duì)列的知識(shí)，可自行搜索相關(guān)資料下偶芍，這里就不闡述了充择。前段時(shí)間買了本關(guān)于RabbitMQ方面的書籍，等看完了腋寨，也希望能單獨(dú)寫一篇關(guān)于消息隊(duì)列的文章聪铺，敬請(qǐng)期待！
