zoukankan      html  css  js  c++  java
  • RabbitMQ消息机制单人分发

     static void Main(string[] args)
            {
    
               // More.SendMessage();
    
                var factory = new ConnectionFactory();
                factory.HostName = "192.168.1.117";
                factory.UserName = "witbank";
                factory.Password = "123456";
    
    
    
                using (var connection = factory.CreateConnection())
                {
                    using (var channel = connection.CreateModel())
                    {
                        channel.QueueDeclare("hello", false, false, false, null);
                        while (true)
                        {
                            string message = "请输入要发送的信息";
    
                            Console.WriteLine(message);
                            message = Console.ReadLine();
                            var properties = channel.CreateBasicProperties();
                            properties.DeliveryMode = 2;
                            var body = Encoding.UTF8.GetBytes(message);
                            channel.BasicPublish("", "hello", null, body);
                            Console.WriteLine(" set {0}", message);
                        }
                    }
                }
            }
    

      

       static void Main(string[] args)
            {
                // More.ReceiveMessage();
    
    
                var factory = new ConnectionFactory();
                factory.HostName = "192.168.1.117";
                factory.UserName = "witbank";
                factory.Password = "123456";
    
                using (var connection = factory.CreateConnection())
                {
                    using (var channel = connection.CreateModel())
                    {
                        channel.QueueDeclare("hello", false, false, false, null);
    
                        var consumer = new QueueingBasicConsumer(channel);
                        channel.BasicConsume("hello", true, consumer);
    
                        Console.WriteLine(" waiting for message.");
                        while (true)
                        {
                            var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
    
                            var body = ea.Body;
                            var message = Encoding.UTF8.GetString(body);
                            Console.WriteLine("Received {0}", message);
    
                        }
                    }
                }
            }
    

      

  • 相关阅读:
    【算法】欧几里德算法--求最大公约数
    g++编译器的使用
    How arduino IDE works?
    【算法】反转链表
    判断一个数是否含有相同的数字
    Java集合ArrayList源码解读
    【算法】二分查找
    移动架构-原型模式
    移动架构-单例模式
    移动架构-简单工厂模式
  • 原文地址:https://www.cnblogs.com/happygx/p/6114071.html
Copyright © 2011-2022 走看看