原文:RabbitMQ指南之三：发布/订阅模式（Publish/Subscribe） 在上一章中，我们创建了一个工作队列，工作队列模式的设想是每一条消息只会被转发给一个消费者。本章将会讲解完全不一样的场景： 我们会把一个消息转发给多个消费者，这种模式称之为发布-订阅模式。 为了阐述这个模式，我们将会... ...
分类：
其他好文 时间：
2019-05-04 16:18:37
阅读次数：
194
原文:RabbitMQ指南之二：工作队列（Work Queues） 在上一章的指南中，我们写了一个命名队列：生产者往该命名队列发送消息、消费从从该命名队列中消费消息。在本章中，我们将创建一个工作队列，用于在多个工作者之间分配耗时的任务。工作队列(即任务队列)的主要思想是避免立即执行那些需要等他们执行... ...
分类：
其他好文 时间：
2019-05-04 16:17:24
阅读次数：
134
在上一章中，我们创建了一个工作队列，工作队列模式的设想是每一条消息只会被转发给一个消费者。本章将会讲解完全不一样的场景： 我们会把一个消息转发给多个消费者，这种模式称之为发布-订阅模式。 为了阐述这个模式，我们将会搭建一个简单的日志系统，它包含两种程序：一种发送日志消息，另一种接收并打印日志消息。在 ...
分类：
其他好文 时间：
2019-05-01 18:31:17
阅读次数：
161
在上一章的指南中，我们写了一个命名队列：生产者往该命名队列发送消息、消费从从该命名队列中消费消息。在本章中，我们将创建一个工作队列，用于在多个工作者之间分配耗时的任务。工作队列(即任务队列)的主要思想是避免立即执行那些需要等他们执行完成的资源密集型任务。相反，我们将任务安排在稍后完成。我们将任务封装 ...
分类：
其他好文 时间：
2019-05-01 01:24:03
阅读次数：
112
工作队列比简单队列在消费者这边多了一个方法。 channel.basicQos(1);公平队列消费(参数设置为1，表示消费者消费完一条才会去接受再次发来的消息) 生产者： 消费者1： 消费者2： ...
分类：
其他好文 时间：
2019-04-06 09:17:43
阅读次数：
107
线程池 运行过程 刚开始都是在创建新的线程，达到核心线程数量5个后，新的任务进来后不再创建新的线程，而是将任务加入工作队列，任务队列到达上线5个后，新的任务又会创建新的线程，直到达到线程池最大的线程数量10个，后面的任务则根据配置的饱和策略来处理。我们这里没有具体配置，使用的是默认的配置AbortP ...
分类：
编程语言 时间：
2019-03-25 23:31:35
阅读次数：
211
工作队列，又称任务队列，主要思想是避免立即执行资源密集型任务，并且必须等待完成。相反地，我们进行任务调度，我们将一个任务封装成一个消息，并将其发送到队列。工作进行在后台运行不断的从队列中取出任务然后执行。当你运行了多个工作进程时，这些任务队列中的任务将会被工作进程共享执行。 这个概念在 Web 应用 ...
分类：
其他好文 时间：
2019-03-12 21:08:38
阅读次数：
155
1.kubectl提交创建pod命令,api响应命令,通过一系列认证授权,把pod数据存储到etcd,创建deployment资源并初始化.2.controller通过list-watch机制,监测发现新的deployment,将该资源加入到内部工作队列,发现该资源没有关联的pod和replicaset,启用deploymentcontroller创建replicaset资源,再启用replica
分类：
其他好文 时间：
2019-03-12 12:16:19
阅读次数：
274
2.2.2 在阅读《深入Linux内核架构与底层原理》 作者：刘京洋 韩方，发现一些错误，有些自己的理解，特以此记录 1、工作队列（workqueue） 队列是一种可以先进先出的数据结构，常常用来将一些工作任务缓冲的情况中。在linux下的workqueue可以用来处理内核中的任务链。 linux内 ...
分类：
系统相关 时间：
2019-03-10 09:34:41
阅读次数：
225
提交一个任务到线程池中，线程池的处理流程如下： 1、判断线程池里的核心线程是否都在执行任务，如果不是（核心线程空闲或者还有核心线程没有被创建）则创建一个新的工作线程来执行任务。如果核心线程都在执行任务，则进入下个流程。 2、线程池判断工作队列是否已满，如果工作队列没有满，则将新提交的任务存储在这个工 ...
分类：
编程语言 时间：
2019-02-27 17:32:33
阅读次数：
189
