二、”工作队列”
在第一节中我们发送接收消息直接从队列中进行。这节中我们会创建一个工作队列来分发处理多个工作者中的耗时性任务。
工作队列主要是为了避免进行一些必须同步等待的资源密集型的任务。实际上我们将这些任务时序话稍后分发完成。我们将某个任务封装成消息然后发送至队列，后台运行的工作进程将这些消息取出然后执行这些任务。当你运行多个工作进程的时候，这些任务也会在它们之间共享。
前期准备
上一节的练习中我们发送的是简单包含“Hello World!”的消息，这节我们还发送字符串不过用此代表更复杂的任务，实际我们这里并没有真正的任务，像图片缩放或pdf文件渲染之类的，这里我们假装我们很忙（即处理的消息任务很耗时），使用time.Sleep函数实现。我们用字符串中的”.”符号的数量代表任务的复杂性，每一个”.”需要耗时1s来执行处理。比如：”Hello…”代表该消息处理耗时3s。
我们稍微修改下上节中send.go代码，为了可以在命令行直接发送任意数量的消息。该程序将任务发送到我们的队列，暂且命名为new_task.go：
body := bodyFrom(os.Args) err = ch.Publish( "", // exchange q.Name, // routing key false,延伸阅读
- ssh框架 2016-09-30
- 阿里移动安全 [无线安全]玩转无线电——不安全的蓝牙锁 2017-07-26
- 消息队列NetMQ 原理分析4-Socket、Session、Option和Pipe 2024-03-26
- Selective Search for Object Recognition 论文笔记【图片目标分割】 2017-07-26
- 词向量-LRWE模型-更好地识别反义词同义词 2017-07-26
- 从栈不平衡问题 理解 calling convention 2017-07-26
- php imagemagick 处理 图片剪切、压缩、合并、插入文本、背景色透明 2017-07-26
- Swift实现JSON转Model - HandyJSON使用讲解 2017-07-26
- 阿里移动安全 Android端恶意锁屏勒索应用分析 2017-07-26
- 集合结合数据结构来看看(二) 2017-07-26
学习是年轻人改变自己的最好方式