RabbitMQ 一二事 簡單佇列使用

2021-09-22 13:18:02 字數 2448 閱讀 4941

訊息佇列目前流行的有三種

1. rabbitmq

2. activemq

3. kafka

這三種都非常強大，rabbitmq目前用的比較多，也比較流行，阿里也在用

activemq是阿帕奇出品，但是效能上和rmq相比相對差一些

卡夫卡呢，使用場景不同，不多介紹，主要是用於日誌收集方面，結合hadoop非常靈活

rabbitmq官網：

我在linux虛擬機上安裝的，安裝步驟簡單，rpm直接安裝就行，步驟就略了 

成功後可以看到如下頁面：

簡答佇列圖

pom方面需要引入如下jar包

1


<


dependencies


>23


<


dependency


>


4<


groupid


>com.rabbitmq


groupid


>


5<


artifactid


>amqp-client


artifactid


>


6<


version


>3.4.1


version


>


7dependency


>89


<


dependency


>


10<


groupid


>org.slf4j


groupid


>


11<


artifactid


>slf4j-log4j12


artifactid


>


12<


version


>1.7.7


version


>


13dependency


>


1415


<


dependency


>


16<


groupid


>org.apache.commons


groupid


>


17<


artifactid


>commons-lang3


artifactid


>


18<


version


>3.3.2


version


>


19dependency


>


2021


<


dependency


>


22<


groupid


>org.springframework.amqp


groupid


>


23<


artifactid


>spring-rabbit


artifactid


>


24<


version


>1.5.6.release


version


>


25dependency


>


2627


dependencies


>
定義乙個類似連線池的類

public


class


connectionutil 


}
建立生產者

1


public


class


send 


23 }
建立消費者

1


public


class


recv 25}


26 }
debug的時候可以進入rmq的管理頁面檢視對於的連線數，頻道，以及訊息佇列：

消費者接受到的訊息：

對應的官網英文文件如下：

getstarted.html

RabbitMQ 二 簡單佇列

參考 簡單佇列的模型 p 生產者,即 producer c 消費者,即 consumer hello 訊息 紅色方塊即佇列 首先新建乙個工具類,方便獲取連線.public static class connectionhelper return factory.createconnection 建立...

RabbitMQ 二 簡單佇列

參考 簡單佇列的模型 p 生產者,即 producer c 消費者,即 consumer hello 訊息 紅色方塊即佇列 首先新建乙個工具類,方便獲取連線.public static class connectionhelper return factory.createconnection 建立...

RabbitMQ 一二事 5 萬用字元模式應用

之前的路由模式是通過key相等來匹配 而萬用字元，顧名思義，符合條件，則進行訊息匹配傳送 將路由鍵和某模式進行匹配。此時佇列需要繫結要乙個模式上。符號 匹配乙個或多個詞，符號 匹配不多不少乙個詞。因此 audit.能夠匹配到 audit.irs.corporate 但是 audit.只會匹配到 au...