登录注册写文章

RabbitMQ的安装及简单使用

RabbitMQ的安装及简单使用

RabbitMQ 安装(linux):

1.安装Erlang-----------------------------------------

RabbitMQ是基于erlang语言进行开发的，所以安装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编译-------------------

（执行的时候需要一定的时间）

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

1.5安装-------------------

(执行的时候需要一定的时间)

编译完成之后直接输入命令：make install

1.6删除安装包-------------------

（可以执行也可以不执行）

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需要在这台服务器上使用

为什么空格后面对应的内容写zookeeper

因为当前这台服务器的hostname配置是zookeeper

如何查看当前服务器的hostname的配置

使用命令 cat /etc/hostname

2.3启动后台web管理功能（需要切换到sbin目录下执行)-------

./rabbitmq-plugins enable rabbitmq_management

然后通过http://192.168.65.131:15672访问默认

用户guest、密码 guest，

登录会提示User can only log in via localhost

这里提示guest用户只能在本地登录，这个时候我们远程访问需要自己添加用户和相应的权限。

添加用户:./rabbitmqctl add_user admin admin

这句话的意思是添加一个用户账号是admin 密码是admin

添加权限:./rabbitmqctl set_permissions -p "/" admin "." "." ".*"

这句的意思是给所有的虚拟机主机添加所有的权限

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

这句话的意思是给admin添加一个标签标签是administrator

然后使用admin进行登录即可:

2.4关闭rabbitmq服务器（切换到sbin目录下执行):-------------------

./rabbitmqctl shutdown

2.5关闭后台web管理功能 :-------------------

./rabbitmq-plugins disable rabbitmq_management

RabbitMQ部分内容参考了： https://www.sojson.com/blog/48.html

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

RabbitMQ提供方上传消息流程

1.启动后台web管理功能（需要切换到sbin目录下执行）-------------------

./rabbitmq-plugins enable rabbitmq_management

2.在需要使用RabbitMQ的API项目中导入依赖----------------------

<dependency>

<groupId>com.rabbitmq</groupId>

<artifactId>amqp-client</artifactId>

<version>5.8.0</version>

</dependency>

3.创建连接工厂---------------------------------------------------

ConnectionFactory connectionFactory = new ConnectionFactory();

4.设置RabbitMQ安装的服务器的地址--------------------------------

connectionFactory.setHost("192.168.80.3");

5.设置RabbitMQ的端口号----------------------------------------

connectionFactory.setPort(5672);

6.设置登录用户和密码---------------------------------------

connectionFactory.setUsername("admin");

connectionFactory.setPassword("admin");

7.设置指定虚拟机:/为默认-----------------------------------

connectionFactory.setVirtualHost("/");

8.创建与RabbitMQ服务的TCP链接-----------------------------

connection = connectionFactory.newConnection();

9.创建于Exchange的通道,每个连接可以创建多个通道,每个通道代表一个会话任务----------------------------------------------------------

channel = connection.createChannel();

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

* 声明队列:如果RabbitMQ中没有此队列将自动创建

* param1:队列的名称

* param2:是否持久化(rabbit重启后,该队列是否还存在)

* param3:队列是否独占此链接(其他队列不能使用此链接)

* param4:队列不再使用时是否自动删除此队列

* param5:队列参数(通常不需要)

* */

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

11.编写要输送的消息------------------------------------------

String data ="来自提供方的郑茜茜"+System.currentTimeMillis();

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

* 消息发布

* param1:Exchange的名称,如果没有指定,则使用Default Exchange

* param2:routingKey,消息的路由Key,是由于Exchange(交换机)将消息发送到指定的消息队列

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

* param4:消息体(需要转成字节数组)

*

* 这里没有定义交换机,消息将发送给默认交换机,每个队列也会绑定那个默认的交换机,但是不能是不绑定或解除绑定

* */

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

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

13.发送完之后就把资源都关闭了,不关闭的话会一直在这里浪费资源---------- if (channel!=null)

{

channel.close();

}

if(connection!=null)

{

connection.close();

}

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

RabbitMQ提供方上传消息流程

1. 创建连接工厂-----------------------------------------

ConnectionFactory connectionFactory = new ConnectionFactory();

2.设置RabbitMQ安装的服务器的地址---------------------

connectionFactory.setHost("192.168.80.3");

3.设置RabbitMQ的端口号---------------------------

connectionFactory.setPort(5672);

4.设置登录用户和密码--------------------------------------

connectionFactory.setUsername("admin");

connectionFactory.setPassword("admin");

5.设置指定虚拟机:/为默认------------------------------

connectionFactory.setVirtualHost("/");

6.创建与RabbitMQ服务的TCP链接------------------------------------

connection = connectionFactory.newConnection();

7.创建于Exchange的通道,每个连接可以创建多个通道,每个通道代表一个会话任务---------------------------------------------------------

channel = connection.createChannel();

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

* 声明队列:如果RabbitMQ中没有此队列将自动创建

* param1:队列的名称

* param2:是否持久化(rabbit重启后,该队列是否还存在)

* param3:队列是否独占此链接(其他队列不能使用此链接)

* param4:队列不再使用时是否自动删除此队列

* param5:队列参数(通常不需要)

* */

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

9.实现消费的方法------------------------------------------

DefaultConsumer defaultConsumer = new DefaultConsumer(channel)

{

/***

* 当接收到消息后此方法将被调用

* @param consumerTag 消费者标签,用于标识消费者的,在监听队列时设置channel,basicConsume(可以不设置)

* @param envelope 信封,通过envelope

* @param properties 消息属性

* @param body 消息内容

* @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();

//接收到的消息的内容

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

System.out.println("从客户端获取到数据为:"+data);

}

};

10.调用实现消费的方法获取数据(监听队列)-------------------------

/***

* 参数:String queue , boolean autoAck , Consumer callback

* 参数明细:

* 1:queue:队列名称

* 2.autoAck:自动回复,当消费者接收到消息后要告诉MQ消息已接收,

* 如果将此参数设置为true表示会自动回复MQ,如果设置为false要通过编程实现回复

* 3.callback:消费方法,当消费者接收到消息,需要执行的方法

*/

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

最后编辑于：2021.11.11 15:22:44

©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容

Spring AMQP中文文档
http://liuxing.info/2017/06/30/Spring%20AMQP%E4%B8%AD%E6%...
sherlock_6981阅读 15,979评论 2赞 11
Rabbitmq
什么叫消息队列？消息（Message）是指在应用间传送的数据。消息可以非常简单，比如只包含文本字符串，也可以更复...
Agile_dev阅读 2,386评论 0赞 24
消息队列RabbitMQ入门与5种模式详解
1.RabbitMQ概述简介： MQ全称为Message Queue，消息队列是应用程序和应用程序之间的通信方法...
梁朋举阅读 50,056评论 0赞 47
RabbitMQ Java客户端API指南
本文章翻译自http://www.rabbitmq.com/api-guide.html，并没有及时更新。术语对...
joyenlee阅读 7,695评论 0赞 3
RabbitMQ快速上手
一、RibbitMQ的基础介绍 1. 为什么要使用MQ2. 与其他MQ的区别 ActiveMQ：使用Java开发，...
団长大人阅读 824评论 0赞 0

1赞2赞

赞赏

手机看全文