[c#]RabbitMQ的简单使用

发布时间：2020-12-15 04:38:02 所属栏目：百科来源：网络整理

导读：摘要安装一个例子 Main( type = (type== = = factory.Port = (IConnection conn = (IModel channel = channel.QueueDeclare( , , , ( message = .Format( [] buffer = = = , + ConnectionFactory factory = = factory.Port = (IConnection conn = (IModel

摘要

安装

一个例子

Main( type = (type=== = factory.Port = (IConnection conn = (IModel channel = channel.QueueDeclare(,,, ( message = .Format([] buffer === , + ConnectionFactory factory = = factory.Port = (IConnection conn = (IModel channel = channel.QueueDeclare(,

                    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;输入1，那如果接收一个消息，但是没有应答，则客户端不会收到下一个消息</span>
                    channel.BasicQos(<span style="color: #800080;"&gt;0</span>,<span style="color: #800080;"&gt;1</span>,<span style="color: #0000ff;"&gt;false</span><span style="color: #000000;"&gt;);

                    Console.WriteLine(</span><span style="color: #800000;"&gt;"</span><span style="color: #800000;"&gt;Listening...</span><span style="color: #800000;"&gt;"</span><span style="color: #000000;"&gt;);

                    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;在队列上定义一个消费者</span>
                    QueueingBasicConsumer consumer = <span style="color: #0000ff;"&gt;new</span><span style="color: #000000;"&gt; QueueingBasicConsumer(channel);
                    </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;消费队列，并设置应答模式为程序主动应答</span>
                    channel.BasicConsume(<span style="color: #800000;"&gt;"</span><span style="color: #800000;"&gt;MyRabbitMQ</span><span style="color: #800000;"&gt;"</span>,<span style="color: #0000ff;"&gt;false</span><span style="color: #000000;"&gt;,consumer);

                    </span><span style="color: #0000ff;"&gt;while</span> (<span style="color: #0000ff;"&gt;true</span><span style="color: #000000;"&gt;)
                    {
                        </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;阻塞函数，获取队列中的消息</span>
                        BasicDeliverEventArgs ea =<span style="color: #000000;"&gt; (BasicDeliverEventArgs)consumer.Queue.Dequeue();
                        </span><span style="color: #0000ff;"&gt;byte</span>[] bytes =<span style="color: #000000;"&gt; ea.Body;
                        </span><span style="color: #0000ff;"&gt;string</span> str =<span style="color: #000000;"&gt; Encoding.UTF8.GetString(bytes);

                        Console.WriteLine(</span><span style="color: #800000;"&gt;"</span><span style="color: #800000;"&gt;队列消息:</span><span style="color: #800000;"&gt;"</span> +<span style="color: #000000;"&gt; str.ToString());
                        </span><span style="color: #008000;"&gt;//</span><span style="color: #008000;"&gt;回复确认</span>
                        channel.BasicAck(ea.DeliveryTag,<span style="color: #0000ff;"&gt;false</span><span style="color: #000000;"&gt;);
                    }
                }
            }
        }

    }
}</span></pre>

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!