作为《学习RabbitMQ，这里没有废话》系列的开篇，理论上按照我个人的风格是要介绍一下什么是消息，什么是消息中间件，然后再过渡到本篇《RabbitMQ：安装》。但之前在《学习RocketMQ，这里没有废话》系列的开篇《RocketMQ：消息中间件简介》已经做过介绍，所以这里就不多说了，下面直接进入今天的主题。
RabbitMQ是当前最主流的消息中间件之一。RabbitMQ是一个开源的AMQP实现，服务器端用Erlang语言编写，支持多种客户端，如：Python、Java、JMS、C、PHP等，支持AJAX。用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。
1. 准备工作
安装之前，当然是要下载RabbitMQ。RabbitMQ当前最新版本：3.8.5，本次我们使用的是3.8.3这个版本。
因为RabbitMQ是由Erlang语言编写，所以在安装RabbitMQ之前，我们需要安装Erlang的环境。本次我们使用的是22.1这个版本。
- Erlang下载地址：http://erlang.org/download/
需要注意的是，RabbitMQ和Erlang之间是有版本依赖关系的，我们可以在这里查找。
2. 安装Erlang
（1）先解压tar.gz文件到/usr/local/erlang目录下
tar -zxvf opt_src_22.1.tar.gz
（2）在编译安装之前，先安装一下依赖包
yum -y install make gcc gcc-c++ kernel-devel m4 ncurses-devel openssl-devel
yum -y install unixODBC unixODBC-devel
（3）编译并安装
cd otp_src_22.1
./configure --prefix=/usr/local/erlang
make && make install
（4）配置环境变量
vim /etc/profile
PATH=$PATH:/usr/local/erlang/bin
source /etc/profile
（5）使用erl命令检查是否安装成功
3. 安装RabbitMQ
（1）解压到/usr/local/rabbitmq目录下
xz -d rabbitmq-server-generic-unix-3.8.3.tar.xz
tar xf rabbitmq-server-generic-unix-3.8.3.tar
mv rabbitmq_server-3.8.3/ /usr/local/rabbitmq/
（2）安装必要的环境
yum install python -y
yum install xmlto -y
yum install python-simplejson -y
（3）配置环境变量
vim /etc/profile
PATH=$PATH:/usr/local/rabbitmq/rabbitmq_server-3.8.3/sbin
source /etc/profile
4. 启动和关闭RabbitMQ服务
- 启动
# 后台启动
rabbitmq-server -detached
- 停止
rabbitmqctl stop
- 查看服务状态
rabbitmqctl status
4.1 开启web管理界面插件
RabbitMQ的优势之一是提供了丰富的界面管理平台，但默认情况下该插件是不开启的。所以我们需要手动开启。
rabbitmq-plugins enable rabbitmq_management
开启后，通过浏览器访问http://localhost:15672，用户名和密码都是guest。
需要注意的是，guest用户只能在localhost环境下登录，如果我们在宿主机去访问虚拟机的RabbitMQ管理界面使用guest用户是不允许登录的。
既然guest用户不允许在宿主机登录，我们则需要自己添加一个用户。
4.2 创建远程登录用户
（1）添加一个用户
rabbitmqctl add_user root rabbitmq
（2）给root用户设置权限
rabbitmqctl set_permissions -p / root ".*" ".*" ".*"
（3）赋予root用户管理员权限
rabbitmqctl set_user_tags root administrator
此时再用root用户即可登录web管理界面了。
5. 测试RabbitMQ
Maven依赖：
<dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>5.7.3</version>
</dependency>
5.1 发送消息
public class BaseProducer {
private static final String EXCHANGE_NAME = "demo.direct";
private static final String ROUTING_KEY = "demo.routingkey";
private static final String QUEUE_NAME = "demo.queue";
public static void main(String[] args) throws Exception {
ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost("192.168.1.17");
connectionFactory.setUsername("root");
connectionFactory.setPassword("rabbitmq");
Connection connection = connectionFactory.newConnection();
Channel channel = connection.createChannel();
channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.DIRECT, true, false, null);
channel.queueDeclare(QUEUE_NAME, true, false, false, null);
channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, ROUTING_KEY);
String message = "Hello World!";
channel.basicPublish(EXCHANGE_NAME, ROUTING_KEY, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());
channel.close();
connection.close();
}
}
5.2 接收消息
public class BaseConsumer {
private static final String QUEUE_NAME = "demo.queue";
public static void main(String[] args) throws Exception {
ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost("192.168.1.17");
connectionFactory.setUsername("root");
connectionFactory.setPassword("rabbitmq");
Connection connection = connectionFactory.newConnection();
Channel channel = connection.createChannel();
Consumer consumer = new DefaultConsumer(channel) {
@Override
public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
System.out.println("message：" + new String(body));
channel.basicAck(envelope.getDeliveryTag(), false);
}
};
channel.basicConsume(QUEUE_NAME, consumer);
}
}
网友评论