原文:RabbitMQ指南之二：工作队列（Work Queues） 在上一章的指南中，我们写了一个命名队列：生产者往该命名队列发送消息、消费从从该命名队列中消费消息。在本章中，我们将创建一个工作队列，用于在多个工作者之间分配耗时的任务。工作队列(即任务队列)的主要思想是避免立即执行那些需要等他们执行... ...
分类：
其他好文 时间：
2019-05-04 16:17:24
阅读次数：
134
首先Kafka是一个分布式消息队列中间件，Apache顶级项目，https://kafka.apache.org/ 高性能、持久化、多副本备份、横向扩展。 生产者Producer往队列里发送消息，消费者Consumer从队列里消费消息，然后进行业务逻辑。应用场景主要有：解耦、削峰（缓冲）、异步处理、 ...
分类：
其他好文 时间：
2019-05-04 16:16:53
阅读次数：
217
1.理解生产者和消费者问题 没有引入信号量时的生产者和消费者进程，什么情况下会出现结果不唯一？什么情况下会出现永远等待？ 用信号解决生产者和消费者的同步与互斥，要求能自己写出来。 答：在两个进程同时进行时，结果会不唯一，因为不同步。 由于异常的中断，导致判断条件的重复错误，最后导致永远等待。 2.哲 ...
分类：
系统相关 时间：
2019-05-02 23:28:00
阅读次数：
194
使用信号量完成线程间同步，模拟生产者，消费者问题。 【sem_product_consumer.c】 思路分析： 规定： 如果□中有数据，生产者不能生产，只能阻塞。 如果□中没有数据，消费者不能消费，只能等待数据。 定义两个信号量：S满 = 0， S空 = 1 （S满代表满格的信号量，S空表示空格的 ...
分类：
其他好文 时间：
2019-05-02 21:49:05
阅读次数：
145
在上一章的指南中，我们写了一个命名队列：生产者往该命名队列发送消息、消费从从该命名队列中消费消息。在本章中，我们将创建一个工作队列，用于在多个工作者之间分配耗时的任务。工作队列(即任务队列)的主要思想是避免立即执行那些需要等他们执行完成的资源密集型任务。相反，我们将任务安排在稍后完成。我们将任务封装 ...
分类：
其他好文 时间：
2019-05-01 01:24:03
阅读次数：
112
1.理解生产者和消费者问题 （1）没有引入信号量时的生产者和消费者进程，什么情况下会出现结果不唯一？什么情况下会出现永远等待？ 结果不唯一:假如当前的产品数为8，如果生产者生产一件产品投入缓存区，拟执行产品数加一操作；同时消费者取走一样产品，拟执行产品数减一操作；假如两者交替执行加一或减一操作，取决 ...
分类：
系统相关 时间：
2019-04-30 23:55:08
阅读次数：
279
生产者消费者条件变量模型 线程同步典型的案例即为生产者消费者模型，而借助条件变量来实现这一模型，是比较常见的一种方法。假定有两个线程，一个模拟生产者行为，一个模拟消费者行为。两个线程同时操作一个共享资源（一般称之为汇聚），生产向其中添加产品，消费者从中消费掉产品。 ...
分类：
其他好文 时间：
2019-04-30 21:55:23
阅读次数：
117
1.生产者启动开始注册生成者服务 2.消费者启动，获取生产者服务 3.变更时推送服务地址列表，也可以定期抓取 4.根据调用策略调用服务，如果失败了重试另一个地址 5.监控定期采集服务调用次数与调用信息。 dubbo分层 1.service和service impl 2.服务配置 3.代理配置与代理工 ...
分类：
其他好文 时间：
2019-04-30 14:10:33
阅读次数：
113
Top NSD ARCHITECTURE DAY07 案例1：Zookeeper安装 步骤一：安装Zookeeper 案例2：Kafka集群实验 案例3：Hadoop高可用 案例4：高可用验证 1 案例1：Zookeeper安装 1.1 问题 本案例要求： 搭建Zookeeper集群并查看各服务器的 ...
分类：
其他好文 时间：
2019-04-28 18:49:56
阅读次数：
202
RabbitMQ的5种模式与实例 1.1 简单模式Hello World 功能：一个生产者P发送消息到队列Q,一个消费者C接收 生产者实现思路： 创建连接工厂ConnectionFactory，设置服务地址127.0.0.1，端口号5672，设置用户名、密码、virtual host，从连接工厂中获 ...
分类：
其他好文 时间：
2019-04-28 15:49:39
阅读次数：
156
