windows下安装RabbitMQ消息服务器 + 读写队列
RabbitMQ是什么 ?
RabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统。他遵循Mozilla Public License开源协议。
1:安装RabbitMQ需要先安装Erlang语言开发包。下载地址 http://www.erlang.org/download.html 在win7下安装Erlang最好默认安装。
配置环境变量 ERLANG_HOME C:\Program Files (x86)\erl5.9
添加到PATH %ERLANG_HOME%\bin;
2:安装RabbitMQ 下载地址 http://www.rabbitmq.com/download.html 安装教程:http://www.rabbitmq.com/install-windows.html
配置环境变量 C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-2.8.0
添加到PATH %RABBITMQ_SERVER%\sbin;
3:进入%RABBITMQ_SERVER%\sbin 目录以管理员身份运行 rabbitmq-plugins.bat
安装完成之后以管理员身份启动 rabbitmq-service.bat
4:浏览器访问localhost:55672 默认账号:guest 密码:guest
创建队列名称为queue_sina ,java示例代码读写队列中queue_sina的消息queue_sina
private static final String exchangeName = "sina";
private static final String exchangeRoutingKey = "sina";
HashMap<String,String> map = new HashMap<String,String>();
map.put("text", request.getText());
map.put("image", imageUrl);
map.put("nick_name", this.getUserName(request.getUserid()));
map.put("shop_name", request.getShopname());
String tousu_map = gson.toJson(map, new TypeToken<HashMap<String,String>>(){}.getType());
System.out.println("tousu_map" + tousu_map);
//写入队列
Producer.sendMsg(PropsUtils.getInstance().getProperty(Constants.EXCHANGE_NAME,
exchangeName), PropsUtils.getInstance()
.getProperty(Constants.EXCHANGE_ROUTING_KEY,
exchangeRoutingKey), tousu_map);
//写入队列模版类
public class Producer {
private static AmqpTemplate amqpTemplate = null;
static {
ApplicationContext context = new AnnotationConfigApplicationContext(TousuConfiguration.class);
amqpTemplate = context.getBean(AmqpTemplate.class);
}
public static void sendMsg(String exchangeName,String routingKey,Object message){
amqpTemplate.convertAndSend(exchangeName, routingKey,message);
System.out.println("exchangeName: "+exchangeName);
System.out.println("routingKey: "+routingKey);
System.out.println("Sent : "+message);
}
}
//读取队列消息
public static void main(String[] args) {
//test
try {
//队列名称 PropertiesUtil.QUEUE_NAME=queue_sina
String queueName = PropertiesUtil.QUEUE_NAME;
ConnectionFactory factory = new ConnectionFactory();
//PropertiesUtil.HOST = localhost
factory.setHost(PropertiesUtil.HOST);
//PropertiesUtil.USER=guest
factory.setUsername(PropertiesUtil.USER);
//PropertiesUtil.PASS=guest
factory.setPassword(PropertiesUtil.PASS);
//PropertiesUtil.PORT=5672
factory.setPort(Integer.parseInt(PropertiesUtil.PORT));
Connection conn = factory.newConnection();
Channel channel = conn.createChannel();
channel.queueDeclare(queueName, true, false, false, null);
QueueingConsumer consumer = new QueueingConsumer(channel);
channel.basicConsume(queueName, true, consumer);
while(true) {
try {
QueueingConsumer.Delivery delivery = consumer.nextDelivery();
String message = new String(delivery.getBody());
System.out.println(" [x] Received '" + message + "'");
} catch (ShutdownSignalException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
转载于:https://www.cnblogs.com/systemnet123/p/3267967.html
windows下安装RabbitMQ消息服务器 + 读写队列相关推荐
- java连接rabbitmq_Mac / Windows 下安装 RabbitMQ
Java大联盟 致力于最高效的Java学习 关注 什么是 RabbitMQ ? RabbitMQ 是采用 Erlang 语言实现 AMQP(Advanced Message Queuing Pro ...
- windows下安装RabbitMQ
windows下安装RabbitMQ 下载Erlang,官方下载中心 erlang下载,http://www.erlang.org/ 本机是win10 64位操作系统,下载64位.exe安装包 安装包 ...
- Windows下安装RabbitMQ报错:unable to perform an operation on node时的解决方案
Windows下安装RabbitMQ报错:unable to perform an operation on node时的解决方案 参考文章: (1)Windows下安装RabbitMQ报错:unab ...
- windows下 安装 rabbitMQ 及操作常用命令
rabbitMQ是一个在AMQP协议标准基础上完整的,可服用的企业消息系统.它遵循Mozilla Public License开源协议,采用 Erlang 实现的工业级的消息队列(MQ)服务器,Rab ...
- RabbitMQ实例教程:Windows下安装RabbitMQ
(1)下载RabbitMQ服务器 从RabbitMQ官网下载最新的稳定版.目前最新版本为3.5.1. (2)移除RabbitMQ老版本. 如果之前安装了老版本的话,或者想要将Erlang VM从32位 ...
- windows下安装rabbitMQ教程(实战书写)
转载自 https://blog.csdn.net/xiaopu99/article/details/79109584 第一步:需要下载安装erlong环境.地址是:http://www.erlang ...
- windows 下安装 rabbitmq报init terminating in do_boot错误
好长时间没有写东西了,记一个安装笔记吧. 目前市面上比较常用的几个消息中间件,rabbitmq算是风评比较好的,所以就拿来安装一下玩玩喽(很有可能也仅限于是安装一下....)安装过程不表,无非是下载E ...
- windows 下安装rabbitmq
2019独角兽企业重金招聘Python工程师标准>>> 1.下载 下载地址:http://www.rabbitmq.com/download.html 2.Windows上安装 2. ...
- Windows下安装NTP时间同步服务器
[实验系统版本为WIndows Server 2008 R2 Enterprise] 1.修改NTP服务相关注册表 #打开"运行" #打开注册表(regedit) #注册表定位到 ...
最新文章
- 东汉末年,他们把「服务雪崩」玩到了极致(干货)
- Zabbix 安装部署
- python登录网页版微信发送消息
- 笔记-计算机网络基础-计算机网络分类
- CSS布局奇技淫巧:各种居中
- matlab华侨大学,闫铮-华侨大学-信息科学与工程学院
- python按列读取txt文件_如何使用pandas读取txt文件中指定的列(有无标题)
- linux定时器tinner,第三章 套接字相关数据结构--基于Linux3.10
- Android studio 如何导入并引用Library工程
- Vue项目中直接调用打印机打印网页的某一区域的方法
- java软件工程师是做什么的_JAVA软件工程师是做什么的?
- 潮汕“木塞”(“木虱”)概率计算
- 前端原生开发解决方案
- UIDocumentPickerViewController docx xlsx
- 台计算机的本地打印机 并且,三台电脑,怎么共用一台打印机?
- 一个链接直接curl可以访问,但是restTemplate访问不了
- pyautogui 鼠标键盘自动化 库的中文版
- js直接调用系统打印机进行打印
- C# HMACSHA1 加密
- 利用matlab的newff构建BP神经网络来实现数据的逼近和拟合
热门文章
- 电路知识--认识原理图(三)
- 常用七大经典排序算法总结(C语言描述)
- RTK无人机应用市场
- [NOTE] sqli-labs Basic Challenges
- C++文件打开模式详解
- [BUUCTF-pwn]——picoctf_2018_buffer overflow 2
- 回溯法——打印子集树
- linux下搭建ntp服务,Linux 下快速搭建ntp 时间同步服务器
- mysql性能测试工具msyqlslap_MySQL性能测试工具 mysqlslap
- 根据pid判断某个进程是否存在