Rabbitmq的使用及Web监控工具使用
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了Rabbitmq的使用及Web监控工具使用，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3141字，纯文字阅读大概需要5分钟。
内容图文
本文转载自：https://www.cnblogs.com/gossip/p/4475978.html
windows安装手册请参考:http://www.rabbitmq.com/install-windows-manual.html
一、文档资料
32位：OTP 17.5 Windows 32-bit Binary File (91.0 MB)
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
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);
}
}
}
}
}
}
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); } } } } }
六、异常问题
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;
原文：https://www.cnblogs.com/yi/p/8977954.html
内容总结
以上是互联网集市为您收集整理的Rabbitmq的使用及Web监控工具使用全部内容，希望文章能够帮你解决Rabbitmq的使用及Web监控工具使用所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。