标签：com 文件 4.4 producer namespace oca rabbitmq 示例 tar
1.下载安装 Erlang 运行时环境
2.下载安装 RabbitMQ Server 应用程序
3.启动 RabbitMQ 服务（默认启动）
4.安装管理平台插件并打开远程访问权限
4.1.打开 RabbitMQ Comman Prompt
4.2.执行 rabbitmq-plugins enable rabbitmq_management
4.3.访问 http://localhost:15672 查看 RabbitMQ Server 相关信息（默认账密为guest）
4.4.新增远程访问用户
4.5.点击 Set permission 授权给新用户
4.6.停止 RabbitMQ 服务
4.7.修改 ...\rabbitmq_server-3.6.10\etc\rabbitmq.config.example 文件（新增第18行代码）
4.8.启动 RabbitMQ 服务
4.9.访问 http://IP:15672 测试是否成功
在 .NET 中使用 RabbitMQ 需要下载它的客户端程序集来获取并引用 RabbitMQ 相关的组件。
1 using RabbitMQ.Client; 2 using System; 3 using System.Text; 4 5 //消息生产者控制台 6 namespace Producer 7 { 8 class Program 9 { 10 static void Main(string[] args) 11 { 12 //创建连接工厂对象 13 var factory = new ConnectionFactory 14 { 15 //目标主机IP或名称 16 HostName = "10.202.228.107", 17 //RabbitMQ Server的用户名称 18 UserName = "Tua", 19 //RabbitMQ Server的密码 20 Password = "Tua", 21 //RabbitMQ Server的默认端口号是5672可以不用指定 22 Port = 5672 23 }; 24 //创建连接对象 25 using (var connection = factory.CreateConnection()) 26 { 27 //创建消息信道对象 28 using (var channel = connection.CreateModel()) 29 { 30 //创建消息队列，只有在该消息队列不存在时才会创建 31 channel.QueueDeclare 32 ( 33 //消息队列名称 34 queue: "Tua", 35 //是否开启持久，true：即不会因为RabbitMQ服务崩溃重启而丢失消息队列 36 durable: false, 37 //是否开启反外，true：即只允许在当前连接中被访问，当连接断开时会自动清除该消息队列 38 exclusive: false, 39 //是否开启自动删除，true：即当无任何消息消费者时，也就是说最后一个连接断开时会自动清除该消息队列 40 autoDelete: false, 41 //用于消息队列的其它属性（构造参数） 42 arguments: null 43 ); 44 string msg = "Mr.Tua"; 45 //将字符串消息转换成二进制数组 46 var body = Encoding.UTF8.GetBytes(msg); 47 //发送消息，将消息发布到消息队列中 48 channel.BasicPublish 49 ( 50 //消息交换机名称 51 exchange: string.Empty, 52 //路由键名称 53 routingKey: "Tua", 54 //消息的其它属性 55 basicProperties: null, 56 //消息内容 57 body: body 58 ); 59 Console.WriteLine("Producer sent message: {0}", msg); 60 Console.ReadLine(); 61 } 62 } 63 } 64 } 65 }
1 using RabbitMQ.Client; 2 using RabbitMQ.Client.Events; 3 using System; 4 using System.Text; 5 6 //消息消费者控制台 7 namespace Consumer 8 { 9 class Program 10 { 11 static void Main(string[] args) 12 { 13 var factory = new ConnectionFactory 14 { 15 //目标主机为本地 16 HostName = "localhost" 17 }; 18 using (var connection = factory.CreateConnection()) 19 { 20 using (var channel = connection.CreateModel()) 21 { 22 //创建消息队列，用于确保不受发送端和接收端先后启动顺序影响 23 channel.QueueDeclare 24 ( 25 queue: "Tua", 26 durable: false, 27 exclusive: false, 28 autoDelete: false, 29 arguments: null 30 ); 31 //创建消息消费者对象 32 var consumer = new EventingBasicConsumer(channel); 33 //异步接收消息时的回调 34 consumer.Received += (sender, e) => 35 { 36 var body = e.Body; 37 var msg = Encoding.UTF8.GetString(body); 38 Console.WriteLine("Consumer received message: {0}", msg); 39 }; 40 //启动消息消费者 41 //消息消费者处理完消息任务时需要回应消息生产者，使其删除该消息 42 //如果消息消费者没有回应，那么消息生产者会将该消息重新发送给其它消息消费者 43 channel.BasicConsume 44 ( 45 queue: "Tua", 46 //是否自动回应，false:即需要手动进行消息回应 47 noAck: true, 48 consumer: consumer 49 ); 50 Console.ReadLine(); 51 } 52 } 53 } 54 } 55 }
启动消息生产者控制台：
启动消息消费者控制台：
在 RabbitMQ Comman Prompt 中执行 rabbitmqctl list_queues 查看消息队列：
从本示例的运行结果可以看出消息生产者在 RabbitMQ Server 中创建了一个名为 Tua 的消息队列并含有一条 Mr.Tua 的消息，当消息消费者接收到该消息后就会立即删除该消息。
标签：com 文件 4.4 producer namespace oca rabbitmq 示例 tar
原文地址：http://www.cnblogs.com/poepoe/p/7275347.html
