[转]Rabbitmq的使用及Web监控工具使用
2024-10-12 10:42:26
本文转自:https://blog.csdn.net/xingxing513234072/article/details/51014850
一、文档资料
1、官方网站:http://www.rabbitmq.com/
二、安装指南
1、下载并按照OTP(必须在安装RabbitMQ Server前安装):http://www.erlang.org/download.html
32位:OTP 17.5 Windows 32-bit Binary File (91.0 MB)
32位:OTP 17.5 Windows 32-bit Binary File (91.0 MB)
64位:OTP 17.5 Windows 64-bit Binary File (91.1 MB)
2、下载并安装RabbitMQ Server:http://www.rabbitmq.com/download.html
选择windows平台,直接从官方链接下载,同时也可以从github上下载,安装完成后,服务自动启动(services.msc)
3、下载并安装.Net客户端:http://www.rabbitmq.com/dotnet.html
http://www.rabbitmq.com/releases/rabbitmq-dotnet-client/v3.5.1/rabbitmq-dotnet-client-3.5.1-dotnet-4.0.zip
3、下载并安装.Net客户端:http://www.rabbitmq.com/dotnet.html
http://www.rabbitmq.com/releases/rabbitmq-dotnet-client/v3.5.1/rabbitmq-dotnet-client-3.5.1-dotnet-4.0.zip
(选择的是.net 4.0版本,同时也可以通过nuget下载)
三、命令行工具
1、定位到rabbitmq安装目录:
windows 7 cd C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.5.1\sbin
Widows Serve cd /d C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.5.1\sbin
2、执行rabbitmq命令行工具(rabbitmqctl ):
rabbitmqctl -q status //打印了一些rabbitmq服务状态信息,包括内存,硬盘,和使用erlong的版本信息
rabbitmqctl list_queues //查看所有队列消息
四、C#客户端使用
1、服务端代码
- namespace Server
- {
- class Program
- {
- static void Main(string[] args)
- {
- var factory = new ConnectionFactory() { HostName = "localhost" };
- using (var connection = factory.CreateConnection())
- {
- using (var channel = connection.CreateModel())
- {
- //定义队列(hello为队列名)
- channel.QueueDeclare("hello", false, false, false, null);
- var consumer = new QueueingBasicConsumer(channel);
- channel.BasicConsume("hello", true, consumer);
- Console.WriteLine(" [*] Waiting for messages." +
- "To exit press CTRL+C");
- while (true)
- {
- //接受客户端发送的消息并打印出来
- var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
- var body = ea.Body;
- var message = Encoding.UTF8.GetString(body);
- Console.WriteLine(" [x] Received {0}", message);
- }
- }
- }
- }
- }
- }
2、客户端代码
- namespace Client
- {
- class Program
- {
- static void Main(string[] args)
- {
- var factory = new ConnectionFactory() { HostName = "localhost" };
- using (var connection = factory.CreateConnection())
- {
- using (var channel = connection.CreateModel())
- {
- //定义队列(hello为队列名)
- channel.QueueDeclare("hello", false, false, false, null);
- //发送到队列的消息,包含时间戳
- string message = "Hello World!" + "_" + DateTime.Now.ToString();
- var body = Encoding.UTF8.GetBytes(message);
- channel.BasicPublish("", "hello", null, body);
- Console.WriteLine(" [x] Sent {0}", message);
- }
- }
- }
- }
- }
如果启动服务端前启动了客户端,消息就会存放到队列中,da
五、RabbitMQ GUID使用
1、官方提供的一个web管理工具(rabbitmq_management)
2、安装了Rabbitmq后,默认也安装了该管理工具,执行命令即可启动
rabbitmq-plugins enable rabbitmq_management(先定位到rabbitmq安装目录)
3、启动后,直接在浏览器地址输入:http://localhost:15672/ 账号密码都是:guest
六、异常问题
1、None of the specified endpoints were reachable
生产端和消费端的factory参数要统一
var factory = new ConnectionFactory();
factory.UserName = QueueSetttiong.UserName; //用户名,对应Management工具的admin-->user
factory.Password = QueueSetttiong.Password; //密码,对应Management工具的admin-->密码
factory.HostName = QueueSetttiong.HostName; //本地部署服务直接用hostname即可
factory.Port = AmqpTcpEndpoint.UseDefaultPort;
factory.VirtualHost = QueueSetttiong.VirtualHost; //使用默认值: "/"
factory.Protocol = Protocols.DefaultProtocol;
最新文章
- CentOS系统中基于Apache+php+mysql的许愿墙网站的搭建
- RPM方式安装MySQL5.6
- java 项目创建中的问题汇总
- jquery radio
- java代码实现打包多个文件下载功能
- [codeforces 241]C. Mirror Box
- grep的用法
- Android经常使用自己定义控件
- 锋利的Jquery解惑系列(一)------基本概念大锅炖
- CC++初学者编程教程(16) 搭建Xcode cocos2dx开发环境
- Akari谜题(关灯问题)的开灯解法
- 【BZOJ1001】[BeiJing2006]狼抓兔子
- Rigidbody组件及相关API
- 阿里巴巴2016研发project师笔试题
- Python-Web框架之 - 利用SQLALchemy创建与数据库MySQL的连接, 详解用Flask时会遇到的一些大坑 !
- Unable to start embedded container; nested exception is org.springframework.context.ApplicationContextException: Unable to start EmbeddedWebApplicationContext due to missing EmbeddedServletContainerFa
- 利用ZYNQ SOC快速打开算法验证通路(3)——PS端DMA缓存数据到PS端DDR
- docker镜像的使用及相关
- hdu3613 Best Reward manacher+贪心+前缀和
- redis sentinel无法启动问题
热门文章
- easyui时的时间格式yyyy-MM-dd与yyyy-MM-ddd HH:mm:ss
- 解决expect自动登录,rz和sz不能使用问题
- iOS开发之Alamofire源码解析
- 背水一战 Windows 10 (98) - 关联启动: 使用外部程序打开一个文件, 使用外部程序打开一个 Uri
- Html/CSS前端如何实现文字边框阴影
- Java初学者容易犯的代码错误
- Javascript高级编程学习笔记(68)—— 事件(12)设备事件
- node.js服务器搭建
- 《http权威指南》读书笔记7
- OWIN 自托管静态网站