RabbitMQ的安装以及使用(Windows环境)
2021-03-20 11:23
标签:body img stat 连接 启动失败 received dep ref 下载 RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件(亦称面向消息的中间件)。RabbitMQ服务器是用Erlang语言编写的,而集群和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。 上述简介摘自百度百科,相关术语自行百度吧。。。反正我也看不懂,太深奥。 因为RabbitMQ是用Erlang语言编写的,所以要安装RabbitMQ先要安装Erlang。 注意:请确认计算机名为英文,中文可能会导致RabbitMQ启动失败。如果启动失败,请改成英文后,卸载并重新安装 在Path中加入 这里注意,看好你RabbitMQ的安装位置,以及安装的版本,我的版本为3.7.3 在Path中加入 在CMD中进入以下目录,键入如下命令,不出错即可 需要以管理员方式启动CMD 在命令行界面键入如下命令 因为RabbitMQ默认启动的,当键入启动命令时,会出现如下情况,直接关闭RabbitMQ服务,再启动就行。 关闭RabbitMQ服务命令如下: 测试地址 http://localhost:15672/ 直接在项目的pom.xml文件中添加如下依赖 RabbitMQ的安装以及使用(Windows环境) 标签:body img stat 连接 启动失败 received dep ref 下载 原文地址:https://www.cnblogs.com/qingmuchuanqi48/p/12306308.html一、RabbitMQ介绍
1、RabbitMQ简介
2、RabbitMQ简介(白话)
做个比喻:
快递员A需要将一个快递给客户B。
原本:A亲手将快递交给B。
问题:B现在有很多事要做,A只能等着B处理完事情,才能把快递交给他,A就很难受了,送不了几个快递,没法赚钱了。
解决:设置一个快递柜,A把快递放进快递柜,就可以送下一个快递了,B啥时候有空了,去快递柜拿就行了。
总结:快递就是消息,快递柜就是消息队列。快递柜有很多种,菜鸟,丰巢等,RabbitMQ就是其中一种快递柜。
放在程序里举例:
客户提交订单,支付系统——>订单系统,支付系统可能很快就执行完了,但是订单系统要很久才能执行完,每次支付系统都要等待订单系统,服务端速度就会很慢,现在使用RabbitMQ,支付系统支付成功后,发送一个支付成功消息到RabbitMQ,就可以返回前端了,订单系统在获取到消息后,慢慢再执行订单修改的程序。(当然,要考虑到某个系统出了异常怎么办,这个入门先不管,只管正常情况。)二、RabbitMQ的安装
1、Erlang的安装
下载地址: http://www.erlang.org/downloads
根据需要选择版本
选择 Windows 64-bit版,下载完成后直接安装,一直NEXT。(路径自行选择)(官网下载速度会比较慢)2、RabbitMQ安装程序
根据需要选择版本(注意:RabbitMQ和Erlang版本可能存在不匹配情况)
选择Bintray版本,下载完成后直接安装,一直NEXT。(路径自行选择)3、自定义环境变量
(1)erl环境变量配置
ERLANG_HOME=D:\Program\erl9.2
%ERLANG_HOME%\bin;
(2)RabbitMQ环境变量配置
RABBITMQ_SERVER=C:\Program Files\RabbitMQ Server\rabbitmq_server-3.7.3
%RABBITMQ_SERVER%\sbin;
4、激活rabbitmq_management
rabbitmq-plugins.bat enable rabbitmq_management
5、启动RabbitMQ服务
net start RabbitMQ
net stop RabbitMQ
三、RabbitMQ测试
默认的用户名:guest
默认的密码为:guest四、Java客户端测试(maven)
1、maven项目中添加RabbitMQ依赖
2、新建SendMQ类,发送端
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
public class SendMQ {
private final static String QUEUE_NAME = "Hello";
public static void main(String[] args) throws IOException, Exception {
// connection是socket连接的抽象,并且为我们管理协议版本协商(protocol version negotiation),
// 认证(authentication )等等事情。这里我们要连接的消息代理在本地,因此我们将host设为“localhost”。
// 如果我们想连接其他机器上的代理,只需要将这里改为特定的主机名或IP地址。
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
factory.setPort(5672); //默认端口号
factory.setUsername("guest");//默认用户名
factory.setPassword("guest");//默认密码
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
// 接下来,我们创建一个channel,绝大部分API方法需要通过调用它来完成。
// 发送之前,我们必须声明消息要发往哪个队列,然后我们可以向队列发一条消息:
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
String message = "Hello world";
channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
System.out.println(" [x] Sent ‘" + message + "‘");
channel.close();
connection.close();
}
}
3、新建RecvMQ类,接收端
import com.rabbitmq.client.*;
import java.io.IOException;
public class RecvMQ {
private final static String QUEUE_NAME = "Hello";
public static void main(String[] args) throws IOException, Exception {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
factory.setPort(5672);
factory.setUsername("guest");
factory.setPassword("guest");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
Consumer consumer = new DefaultConsumer(channel) {
@Override
public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties,
byte[] body) throws IOException {
String message = new String(body, "UTF-8");
System.out.println(" [x] Received ‘" + message + "‘");
}
};
channel.basicConsume(QUEUE_NAME, true, consumer);
}
}
4、运行两个类测试