zoukankan      html  css  js  c++  java
  • RabbitMQ 官方demo1

    public class RabbitMqSend
        {
            public static void Test()
            {
                var factory = new ConnectionFactory() { HostName = "localhost" };
                using(var conn = factory.CreateConnection())
                using(var channel = conn.CreateModel())
                {
                    channel.QueueDeclare(queue: "hello", durable: true, exclusive: false, autoDelete: false, arguments: null);
                    //消息持久化,durable: true和.Persistent = true 2个都要设置
                    //durable: true-->needs to be applied to both the producer and consumer code.
                    var properties   = channel.CreateBasicProperties();
                    properties.Persistent = true;
    
    
                    string msg = "你好,老大!!!";
                    var body = Encoding.UTF8.GetBytes(msg);
                    channel.BasicPublish(exchange: "", routingKey: "hello", basicProperties: properties, body: body);
                    Console.WriteLine("[x] sent {0}", msg);
                }
            }
        public class RabbitMqTest
        {
            public static void Test()
            {
                var factory = new ConnectionFactory() { HostName = "localhost" };
                using (var connection = factory.CreateConnection())
                using (var channel = connection.CreateModel())
                {
                    //息持久化,durable: true
                    channel.QueueDeclare(queue: "hello",
                                     durable: true,
                                     exclusive: false,
                                     autoDelete: false,
                                     arguments: null);
                    var consumer = new EventingBasicConsumer(channel);
                    consumer.Received += (model, ea) => 
                    {
                        var body = ea.Body;
                        var msg = Encoding.UTF8.GetString(body);
                        Console.WriteLine("[x] received {0}", msg);
                        //发送确认消息,通知改消息处理完成,可以删除
                        channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
                    };
                    //noAck = false 表示需求确认消息已经处理才在服务器中删除,进入下一个消息
                    channel.BasicConsume(queue: "hello", noAck: false, consumer: consumer);
                }
            }
            /*
             * Forgotten acknowledgment
    It's a common mistake to miss the BasicAck. It's an easy error, but the consequences are serious. 
    Messages will be redelivered when your client quits (which may look like random redelivery), 
    but RabbitMQ will eat more and more memory as it won't be able to release any unacked messages.
    
    In order to debug this kind of mistake you can use rabbitmqctl to print the messages_unacknowledged field:
    
    $ sudo rabbitmqctl list_queues name messages_ready messages_unacknowledged
    Listing queues ...
    hello    0       0
    ...done.
             */
        }

    启动mq服务:rabbitmq-service.bat

  • 相关阅读:
    Troubleshooting MySQL Memory Usage
    Innodb Log checkpointing 和 dirty Buffer pool pages的关系
    MySQL pager 命令有趣的用法
    测定INNODB REDO LOGS的写入量
    max_allowed_packet & Mysqldump
    链接MyISAM文件
    RFID常识
    C++的程序的文件结构(zt)
    使用C#开发ActiveX控件(zt)
    RFID自动识别术语解释(zt)
  • 原文地址:https://www.cnblogs.com/ly7454/p/5359433.html
Copyright © 2011-2022 走看看