? ? ? ? ? ? ? ? ? ? ? ? ? ? ? RabbitMQ 安裝(linux):

1.安裝Erlang-----------------------------------------

RabbitMQ是基于erlang語言進行開發(fā)的褐桌，所以安裝RabbitMQ之前需要先安裝erlang語言

????1.1安裝erlang前先安裝Linux依賴庫:-------------------

????[if !supportLists]1.?[endif]yum -y install make gcc gcc-c++ kernel-devel ????m4 ncurses-devel openssl-devel

????1.2?解壓erlang壓縮包文件:-------------------

? ? ? ? ? ?tar -zxvf otp_src_21.2.tar.gz?-C /usr/local

????1.3配置-------------------

? （需要切換到解壓目錄下進行操作cd otp_src_21.2）

????然后輸入./configure

????然后回車（進行配置的時候需要一定的時間）

????1.4編譯-------------------

? （執(zhí)行的時候需要一定的時間）

????配置完成之后直接輸入命令：make

????1.5安裝-------------------

? ? (執(zhí)行的時候需要一定的時間)

????編譯完成之后直接輸入命令：make install

????1.6刪除安裝包-------------------

? （可以執(zhí)行也可以不執(zhí)行）

? ? rm -rf otp_src_21.2

????1.7驗證erlang是否安裝成功-------------------

? ? ? ? ? 在命令行輸入：erl如果進入了編程命令行則? ? ? ? ? ? ?表示安裝成功龙亲，

? ? ? ? ? 然后按ctrl + z 退出編程命令行；

2.安裝RabbtiMQ-----------------------------------------

????2.1解壓RabbitMQ的壓縮包:-------------------

????tar -xvf rabbitmq-server-generic-unix-3.8.0.tar.xz ?-C /usr/local/

????.tar.xz文件解壓后就可以使用了聪建，無需再編譯安裝；

????切換到安裝目錄的sbin目錄下:-------------------

????2.2.啟動RabbitMQ----------------------

?????./rabbitmq-server -detached

? ? ?-detached表示后臺啟動

? ? ?如果后臺啟動的時候報錯：

? ? ?解決方案：

? ? ?進入

? ? ?vim /etc/hosts(添加一行映射?映射當前服務器的ip地址與當前的主機host? ? ? ? 名字)

? ? ?注意：為什么這里寫的ip地址是192.168.65.131

? ? ?因為當前rabbitmq需要在這臺服務器上使用

? ? ?為什么空格后面對應的內(nèi)容寫zookeeper

? ? ?因為當前這臺服務器的hostname配置是zookeeper

? ? ?如何查看當前服務器的hostname的配置

? ? ?使用命令?cat?/etc/hostname

? ? ?2.3啟動后臺web管理功能（需要切換到sbin目錄下執(zhí)行)-------

? ? ?????./rabbitmq-plugins enable rabbitmq_management

? ? ? ?然后通過http://192.168.65.131:15672訪問默認

? ? ? ?用戶guest锦溪、密碼 guest参萄，

????????登錄會提示User can only log in via localhost

????????這里提示guest用戶只能在本地登錄累驮，這個時候我們遠程訪問需要自己添? ? ? ? ? 加用戶和相應的權(quán)限。

????????添加用戶:./rabbitmqctl add_user admin admin

????????這句話的意思是添加一個用戶?賬號是admin?密碼是admin

????????添加權(quán)限:./rabbitmqctl set_permissions -p "/" admin ".*" ".*" ".*"

????????這句的意思是給所有的虛擬機主機添加所有的權(quán)限

????????修改用戶角色:./rabbitmqctl set_user_tags admin administrator

????????這句話的意思是給admin添加一個標簽 標簽是administrator

????????然后使用admin進行登錄即可:

????????2.4關(guān)閉rabbitmq服務器（切換到sbin目錄下執(zhí)行):-------------------

? ????????./rabbitmqctl shutdown

????????2.5關(guān)閉后臺web管理功能?:-------------------

????????./rabbitmq-plugins disable rabbitmq_management

RabbitMQ部分內(nèi)容參考了：?https://www.sojson.com/blog/48.html

---------------------------------------------------------------------------------

? ??????????????????????RabbitMQ提供方上傳消息流程

1.啟動后臺web管理功能（需要切換到sbin目錄下執(zhí)行）-------------------

./rabbitmq-plugins enable rabbitmq_management

2.在需要使用RabbitMQ的API項目中導入依賴----------------------

<dependency>

<groupId>com.rabbitmq</groupId>

<artifactId>amqp-client</artifactId>

<version>5.8.0</version>

</dependency>

3.創(chuàng)建連接工廠---------------------------------------------------

?ConnectionFactory connectionFactory = new ConnectionFactory();

4.設(shè)置RabbitMQ安裝的服務器的地址--------------------------------

connectionFactory.setHost("192.168.80.3");

5.設(shè)置RabbitMQ的端口號----------------------------------------

connectionFactory.setPort(5672);

6.設(shè)置登錄用戶和密碼---------------------------------------

connectionFactory.setUsername("admin");? ? ? ? ??

?connectionFactory.setPassword("admin");

7.設(shè)置指定虛擬機:/為默認-----------------------------------

? ? ? ? connectionFactory.setVirtualHost("/");

8.創(chuàng)建與RabbitMQ服務的TCP鏈接-----------------------------

? connection = connectionFactory.newConnection();

9.創(chuàng)建于Exchange的通道,每個連接可以創(chuàng)建多個通道,每個通道代表一個會話任務----------------------------------------------------------

?channel = connection.createChannel();

10./*----------------------------------------------------------

? ? * 聲明隊列:如果RabbitMQ中沒有此隊列將自動創(chuàng)建

? ? * param1:隊列的名稱

? ? * param2:是否持久化(rabbit重啟后,該隊列是否還存在)

? ? * param3:隊列是否獨占此鏈接(其他隊列不能使用此鏈接)

? ? * param4:隊列不再使用時是否自動刪除此隊列

? ? * param5:隊列參數(shù)(通常不需要)

? ? * */

? ? ? ? ? ? channel.queueDeclare("zhengxixi",true,false,false,null);

? ?11.編寫要輸送的消息------------------------------------------

? ? ? ? ? ? String data ="來自提供方的鄭茜茜"+System.currentTimeMillis();

? ?12./*--------------------------------------------------------

? ? * 消息發(fā)布

? ? * param1:Exchange的名稱,如果沒有指定,則使用Default Exchange

? ? * param2:routingKey,消息的路由Key,是由于Exchange(交換機)將消息發(fā)送到指定的消息隊列

? ? * param3:消息包含的屬性(通常不需要)

? ? * param4:消息體(需要轉(zhuǎn)成字節(jié)數(shù)組)

? ? *

? ? * 這里沒有定義交換機,消息將發(fā)送給默認交換機,每個隊列也會綁定那個默認的交換機,但是不能是不綁定或解除綁定

? ? * */

? ? ? ? ? ? channel.basicPublish("","zhengxixi",null,data.getBytes());

? ? ? ? ? ? System.out.println("向RabbitMQ上傳消息:"+data);

? 13.發(fā)送完之后就把資源都關(guān)閉了,不關(guān)閉的話會一直在這里浪費資源----------? ? ? ? ? ? ? ? ? if (channel!=null)

? ? ? ? ? ? {

? ? ? ? ? ? ? ? channel.close();

? ? ? ? ? ? }

? ? ? ? ? ? if(connection!=null)

? ? ? ? ? ? {

? ? ? ? ? ? ? ? connection.close();

? ? ? ? ? ? }

---------------------------------------------------------

? ? ? ? ? ? ? ? ? ? ? ?RabbitMQ提供方上傳消息流程

1. 創(chuàng)建連接工廠-----------------------------------------

?ConnectionFactory connectionFactory = new ConnectionFactory();

2.設(shè)置RabbitMQ安裝的服務器的地址---------------------

connectionFactory.setHost("192.168.80.3");

3.設(shè)置RabbitMQ的端口號---------------------------

connectionFactory.setPort(5672);

4.設(shè)置登錄用戶和密碼--------------------------------------

connectionFactory.setUsername("admin");

connectionFactory.setPassword("admin");

5.設(shè)置指定虛擬機:/為默認------------------------------??

? connectionFactory.setVirtualHost("/");

6.創(chuàng)建與RabbitMQ服務的TCP鏈接------------------------------------

connection = connectionFactory.newConnection();

7.創(chuàng)建于Exchange的通道,每個連接可以創(chuàng)建多個通道,每個通道代表一個會話任務---------------------------------------------------------

? ?channel = connection.createChannel();

8./*-------------------------------------------------

? * 聲明隊列:如果RabbitMQ中沒有此隊列將自動創(chuàng)建

? * param1:隊列的名稱

? * param2:是否持久化(rabbit重啟后,該隊列是否還存在)

? * param3:隊列是否獨占此鏈接(其他隊列不能使用此鏈接)

? * param4:隊列不再使用時是否自動刪除此隊列

? * param5:隊列參數(shù)(通常不需要)

? * */

? channel.queueDeclare("zhengxixi", true, false, false, null);

9.實現(xiàn)消費的方法------------------------------------------

? DefaultConsumer defaultConsumer = new DefaultConsumer(channel)

? {

? ? ? ? ? ? /***

? ? ? ? ? ? * 當接收到消息后此方法將被調(diào)用

? ? ? ? ? ? * @param consumerTag 消費者標簽,用于標識消費者的,在監(jiān)聽隊列時設(shè)置channel,basicConsume(可以不設(shè)置)

? ? ? ? ? ? * @param envelope 信封,通過envelope

? ? ? ? ? ? * @param properties 消息屬性

? ? ? ? ? ? * @param body 消息內(nèi)容

? ? ? ? ? ? * @throws IOException

? ? ? ? ? ? */

? ? ? @Override

? ? ? public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException

? ? ? {

? ? ? ? ? ? ? //獲取交換機

? ? ? ? ? ? ? String exchange = envelope.getExchange();

? ? ? ? ? ? ? //消息id,MQ在channel中用來標識消息的id,可用于確認消息已接受

? ? ? ? ? ? ? long deliveryTag = envelope.getDeliveryTag();

? ? ? ? ? ? ? //接收到的消息的內(nèi)容

? ? ? ? ? ? ? String data = new String(body, "UTF-8");

? ? ? ? ? ? ? System.out.println("從客戶端獲取到數(shù)據(jù)為:"+data);

? ? ? }

? ? };

10.調(diào)用實現(xiàn)消費的方法獲取數(shù)據(jù)(監(jiān)聽隊列)-------------------------

/***

? ? * 參數(shù):String queue , boolean autoAck , Consumer callback

? ? * 參數(shù)明細:

? ? * 1:queue:隊列名稱

? ? * 2.autoAck:自動回復,當消費者接收到消息后要告訴MQ消息已接收,

? ? *? 如果將此參數(shù)設(shè)置為true表示會自動回復MQ,如果設(shè)置為false要通過編程實現(xiàn)回復

? ? * 3.callback:消費方法,當消費者接收到消息,需要執(zhí)行的方法

? ? */

? ? channel.basicConsume("zhengxixi", true, defaultConsumer);