生产者：代码如上一章 消费者1：代码如前一章 消费者2：与消费者1代码完全相同 注意：此时，消费者1和2监听在同一个队列上，队列会以轮训的方式将10个消息分别交给消费者1和2进行处理。 但是这种情况下，如果消费者1处理的消息比较繁重，而消费者2处理的消息比较轻松地话，实际上应该让消费者 ...

生产者：代码如上一章 消费者1：代码如前一章 消费者2：与消费者1代码完全相同 注意：此时，消费者1和2监听在同一个队列上，队列会以轮训的方式将10个消息分别交给消费者1和2进行处理。 但是这种情况下，如果消费者1处理的消息比较繁重，而消费者2处理的消息比较轻松地话，实际上应该让消费者 ...

一、问题答案 　　是不可以的 而且后注册的会替换前注册的，MqConsumer2会替换MqConsumer，并且只结束tag-2的消息 二、为什么呢？ 我 ...

rabbitmq作为消息队列可以有消息消费确认机制，之前写个基于redis的通用生产者 消费者 并发框架，redis的list结构可以简单充当消息队列，但不具备消费确认机制，随意关停程序，会丢失一部分正在程序中处理但还没执行完的消息。基于redis的与基于rabbitmq相比对消息消费速度和消息 ...

单生产者和单消费者的情况下可以不要锁，但是memory barrier还是需要的。 考虑下面一个简单的情况，初始时，data未初始化，flag = 0; 生产者线程： 消费者线程： 这段代码意思是消费者等到生产者把flag置为1后才去读data的值，那么读到 ...

最近做的项目的一个版本需求中，需要用到MQ,对数据记录进行异步落库，这样可以减轻数据库的压力,同时可以抗住大量的数据落库。这里需要说明一下本人用到的MQ是公司自己在阿里的RokectMQ的基础上进行封装的，然后加上自己的东西，形成个性化的开发，且安全性高。这里就不多透露相关公司的信息啦，我就叫 ...

测试结果：客户端的数据总是发给最后一个打开的服务器 服务器代码：socket()->setsockopt()->bind()->recvfrom()/sendto() 客户端代码：socket()->sendto()/recvfrom() ...

通过 fork 创建子进程的方式可以实现父子进程监听相同的端口。 方法：在绑定端口号（bind函数）之后，监听端口号之前（listen函数），用fork（）函数生成子进程，这样子进程就可以克隆父进程，达到监听同一个端口的目的。 惊群现象 当连接到来时，子进程、父进程都可以 accept ...