码迷,mamicode.com
首页 > 其他好文 > 详细

RabbitMQ (八) : 消息确认机制之事务机制

时间:2019-02-07 12:23:02      阅读:228      评论:0      收藏:0      [点我收藏+]

标签:client   work   model   private   吞吐量   额外   mode   rabbit   stat   

实在没啥好说的.

生产者

    public class Producer
    {
        private const string QueueName = "test_work_queue";
        public static void Send()
        {
            //获取一个连接
            IConnection connection = ConnectionHelper.GetConnection();

            //从连接中获取一个通道
            IModel channel = connection.CreateModel();

            //声明队列
            channel.QueueDeclare(QueueName, false, false, false, null);
            
            //创建一个消息
            string msg = "hello world ";
            try
            {
                //开启事务机制
                //事务机制性能不好,不建议使用.因为需要和服务器发生额外的通信,降低了 RabbitMQ 的吞吐量
                channel.TxSelect();

                //发送消息
                channel.BasicPublish("", QueueName, null, Encoding.Default.GetBytes(msg));

                //提交
                channel.TxCommit();
                Console.WriteLine($"send {msg}");
            }
            catch (Exception e)
            {
                //回滚
                channel.TxRollback();
                Console.WriteLine(e);
            }

            channel.Close();
            connection.Close();
        }
    }

 

消费者

    public class Consumer
    {
        private const string QueueName = "test_work_queue";
        public static void Receive()
        {
            //获取连接
            RabbitMQ.Client.IConnection connection = ConnectionHelper.GetConnection();

            //创建通道
            RabbitMQ.Client.IModel channel = connection.CreateModel();

            //声明队列
            channel.QueueDeclare(QueueName, false, false, false, null);

            //添加消费者
            EventingBasicConsumer consumer = new EventingBasicConsumer(channel);

            //注册事件
            consumer.Received += Consumer_Received;

            //监听队列
            channel.BasicConsume(QueueName, true, "", false, false, null, consumer);
        }

        private static void Consumer_Received(object sender, BasicDeliverEventArgs e)
        {
            byte[] bytes = e.Body;
            string str = Encoding.Default.GetString(bytes);
            Console.WriteLine("consumer : " + str);
        }
    }

 

RabbitMQ (八) : 消息确认机制之事务机制

标签:client   work   model   private   吞吐量   额外   mode   rabbit   stat   

原文地址:https://www.cnblogs.com/refuge/p/10351214.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!