zoukankan      html  css  js  c++  java
  • Windows下的RabbitMQ安装:.Net测试RabbitMQ(工作队列模式)

    测试服务器:虚拟机 server 2008R2

    代码测试:vs2012+C#

    代码引入Rabbit.Client.dll

    编写测试代码:

    代码大概意思是链接RabbitMQ发送10条消息。

    消费端代码:

    消费端代码大概意思是链接RabbitMQ处理信息;

    其中BasicQos(0,5,false)“公平调度” 表示服务端向消费端每次最多发送5个消息,防止单次发送消息太多,消费端不能及时处理。

    当多个消费端同时处理一个队列里的消息,不设置BasicQos(0,5,false) 会导致第一个消费端很繁忙,其余消费端很闲;可以设置成BasicQos(0,1,false) ,每次只发一个消息。

    BasicConsume()中第二个参数为“noAck”:是否手动确认,设置为false则启动消息确认机制,BasicAck()为手动确认消息。(没有消息确认机制,服务端发送消息后则会删除这个消息,如果消费端不能正常处理则会导致消息丢失,手动确认则会再代码中处理成功是触发)

    如果消费端是web程序,引用程序池回收、重启或者关闭,消费端断开连接。iis默认是20分钟无动作会自动回收进程,会导致消费者断开连接。(可能会导致的结果是半夜消费端空闲iis回收,第二天消费端不能启动)

    消费端是winform或控制台程序则进程结束会断开连接,有时进程关闭会有部分线程不能关闭,导致rabbit不能正常的断开连接。(winform使用Environment.Exit(0)结束进程)

    ip和端口和发送端不一致是因为我在两台虚拟机上安装了RabbitMQ并且做了集群和镜像。下一篇会介绍做集群的过程。

    消费端可以动态的增加和删除,当消息太多当前的消费端不能快速处理时可以动态增加消费端。

    工作队列方式参考:https://www.cnblogs.com/wyt007/p/9066216.html

    Rabbit相关学习参考:https://www.cnblogs.com/wyt007/category/1218660.html

    仅供参考,内容中会引用部分博友的文章。(侵删)
  • 相关阅读:
    Python 进度条
    python多线程的使用
    Python 进程间通信问题—Manager方法
    生产消费者模型(进程通信,队列)
    进程锁 购票问题
    多进程并行实现socket并发代码
    一次完整的socket文件的传输
    python实现基本计算器(可处理括号和负值)
    模拟论坛登录
    JS
  • 原文地址:https://www.cnblogs.com/zeran/p/10773368.html
Copyright © 2011-2022 走看看