首页 > 其他 > 详细

RabbitMQ 消费端 Client CPU 100%的解决办法

时间:2017-01-09 18:34:31      阅读:1041      评论:0      收藏:0      [点我收藏+]
 Func<bool> run = () =>
            {
                try
                {
                    using (IConnection conn = cf.CreateConnection())
                    {
                        using (IModel channel = conn.CreateModel())
                        {
                            var consumer = createConsumer(channel);
                            while (channel.IsOpen)
                            {
                                Thread.Sleep(10);
                                BasicDeliverEventArgs ea = null;
                                try
                                {
                                    ea = consumer.Queue.DequeueNoWait(null);
                                    if (ea == null) continue;
                                }

                                catch (Exception ex)
                                {
                                    TraceLogHelper.WriteError("RabbitMQ", "【里面】", ex.StackTrace);
                                    break;
                                }
                                var body = ea.Body;
                                var message = Encoding.UTF8.GetString(body);
                                var b = func(message);
                                if (b)
                                {
                                    channel.BasicAck(ea.DeliveryTag, false);
                                    Console.WriteLine("接收消息成功:" + message);
                                }

      
                            }
                        }
                    }
                    return true;
                }
                catch (Exception ex)
                {
                    TraceLogHelper.WriteError("RabbitMQ", "[外层]", ex.StackTrace);
                    return false;
                }
            };

  

增加一个 Thread.Sleep(10);即可解决。

 

以后遇到无线循环的时候,需要加Sleep

RabbitMQ 消费端 Client CPU 100%的解决办法

原文:http://www.cnblogs.com/haoliansheng/p/6265966.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!