2019獨角獸企業(yè)重金招聘Python工程師標(biāo)準(zhǔn)>>>

最近好多項目都有需要是用MQ的場景，以下是在安裝過程記錄的一些知識點，安裝MQ需要先安裝依賴環(huán)境，erlang和socat。 安裝RabbitMQ：

rpm -i --nodeps rabbitmq-server-3.6.10-1.el6.noarch.rpm

啟動mq：

service rabbitmq-server start

創(chuàng)建用戶：

rabbitmqctl add_user admin admin

設(shè)置為管理員：

rabbitmqctl set_user_tags admin administrator

啟動web管理

rabbitmq-plugins enable rabbitmq_management

用剛才創(chuàng)建的用戶登錄web管理頁面，端口默認為15672 我們需要為剛才的admin配置權(quán)限，見上圖，點名字進去即可，conf/write/read 都配成缺省顯示的那個.* 即可。 目前為缺省配置，更多配置見http://www.rabbitmq.com/configure.html#config-items

java項目中加入依賴

<dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>3.0.4</version></dependency>

發(fā)送示例

package com.pactera.business.mq;import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory;public class Send {//隊列名稱 private final static String QUEUE_NAME = "queue"; public static void main(String[] argv) throws java.io.IOException { /** * 創(chuàng)建連接連接到MabbitMQ */ ConnectionFactory factory = new ConnectionFactory(); //設(shè)置MabbitMQ所在主機ip或者主機名 factory.setHost("192.168.0.3"); factory.setUsername("admin");factory.setPassword("admin123");factory.setVirtualHost("/");factory.setPort(5672);//創(chuàng)建一個連接 Connection connection = factory.newConnection(); //創(chuàng)建一個頻道 Channel channel = connection.createChannel(); //指定一個隊列 channel.queueDeclare(QUEUE_NAME, false, false, false, null); //發(fā)送的消息 String message = "test quene"; //往隊列中發(fā)出一條消息 channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); System.out.println("Sent '" + message + "'"); //關(guān)閉頻道和連接 channel.close(); connection.close(); } }

接收示例

package com.pactera.business.mq;import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.QueueingConsumer;public class Recv {//隊列名稱 private final static String QUEUE_NAME = "queue"; public static void main(String[] argv) throws java.io.IOException,java.lang.InterruptedException { //打開連接和創(chuàng)建頻道，與發(fā)送端一樣 ConnectionFactory factory = new ConnectionFactory();//設(shè)置RabbitMQ所在主機ip或者主機名 factory.setUsername("root");factory.setPassword("root");factory.setHost("192.168.0.3");factory.setVirtualHost("/");factory.setPort(5672);Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); //聲明隊列，主要為了防止消息接收者先運行此程序，隊列還不存在時創(chuàng)建隊列。 channel.queueDeclare(QUEUE_NAME, false, false, false, null); System.out.println("Waiting for messages. To exit press CTRL+C"); //創(chuàng)建隊列消費者 QueueingConsumer consumer = new QueueingConsumer(channel); //指定消費隊列 channel.basicConsume(QUEUE_NAME, true, consumer); while (true) { //nextDelivery是一個阻塞方法（內(nèi)部實現(xiàn)其實是阻塞隊列的take方法） QueueingConsumer.Delivery delivery = consumer.nextDelivery(); String message = new String(delivery.getBody()); System.out.println("Received '" + message + "'");} } }

接下來會整合到spring中。

轉(zhuǎn)載于:https://my.oschina.net/scottCoder/blog/1162492

總結(jié)

以上是生活随笔為你收集整理的RabbitMQ 安装和简单测试的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。