一、需求描述 1. 利用Redis做消息队列，实现一个异步化服务框架；如图： 2. 利用搭建好的框架实现异步化发送点赞信息和登录异常信息 。 二、具体diamante实现 首先搭建应用Redis做消息队列的异步化框架 1.准备 JedisAdapter.java 类中加上lpush 和 bpop的代 ...
分类：
其他好文 时间：
2017-05-08 01:22:55
阅读次数：
577
在ThreadPool 类中定义了一个LinkedList 类型的 workQueue 成员变量, 它表示工作队列, 用来存放线程池要执行的任务, 每个任务都是 Runnable 实例. Thread...
分类：
其他好文 时间：
2017-04-27 16:17:41
阅读次数：
244
http://www.rabbitmq.com/getstarted.html官网 最近业务需要使用Rabbitmq工作队列实现任务的负载分发 1.1、什么是RabbitMQ？ RabbitMQ是实现AMQP（高级消息队列协议）的消息中间件的一种，服务器端用Erlang语言编写，支持多种客户端，如： ...
分类：
其他好文 时间：
2017-04-08 09:48:15
阅读次数：
185
RabbitMQ官方中文入门教程(PHP版) 第一部分:Hello World RabbitMQ官方中文入门教程(PHP版) 第二部分:工作队列（Work queues） RabbitMQ官方中文入门教程(PHP版) 第三部分:发布／订阅（Publish/Subscribe） RabbitMQ官方中 ...
分类：
Web程序 时间：
2017-02-09 13:19:07
阅读次数：
175
rabbitmq使用dead letter机制来进行retry 首先建立 工作exchange和工作queue，指定工作队列的x-dead-letter-exchange到重试exchenge var workQueueArgs = new Dictionary<string, object> { ...
分类：
其他好文 时间：
2017-02-07 10:41:58
阅读次数：
197
Remote procedure call (RPC) (using the .NET client) 在第二个教程second tutorial 中我们已经了解到了工作队列如何将耗时任务分配给多个workers。 但是假如我们需要在远端机器上面运行一个函数并且等待结果返回呢？这通常叫做RPC，即远 ...
分类：
Web程序 时间：
2017-02-03 19:26:26
阅读次数：
296
转自：http://www.cnblogs.com/li-hao/archive/2012/01/12/2321084.html 软中断、tasklet和工作队列并不是Linux内核中一直存在的机制，而是由更早版本的内核中的“下半部”（bottom half）演变而来。下半部的机制实际上包括五种，但 ...
分类：
系统相关 时间：
2017-01-22 23:33:44
阅读次数：
349
什么是工作队列 工作队列是为了避免等待一些占用大量资源或时间操作的一种处理方式。我们把任务封装为消息发送到队列中，消费者在后台不停的取出任务并且执行。当运行了多个消费者工作进程时，队列中的任务将会在每个消费者间进行共享。 使用工作队列的好处就是能够并行的处理任务。如果队列中堆积了很多任务，只要添加更... ...
分类：
其他好文 时间：
2016-12-08 18:24:17
阅读次数：
488
rabbitmq 重复确认导致消息丢失 背景 rabbitmq 在应用场景中，大多采用工作队列 work-queue的模式。 在一个常见的工作队列模式中，消费者 worker 将不断的轮询从队列中拉取最新消息，当队列负载压力增大时允许添加多个worker 进行处理。然而执行一个任务可能需要相当的时长 ...
分类：
其他好文 时间：
2016-11-22 09:39:29
阅读次数：
385
"发布订阅" 三、”发布订阅” 上一节的练习中我们创建了一个工作队列。队列中的每条消息都会被发送至一个工作进程。这节，我们将做些完全不同的事情——我们将发送单个消息发送至多个消费者。这种模式就是广为人知的“发布订阅”模式。 为了说明这种模式，我们将构建一个简单的日志系统。包括2个应用程序，一个传送日 ...
分类：
其他好文 时间：
2016-11-13 19:01:33
阅读次数：
196
