Work Queues
(using the Java Client)
In the first tutorial we wrote programs to send and receive messages from a
named queue. In this one we'll create a Work Queue that will be used to distribute
time-consuming tasks among multiple workers.
The main idea behind Work Queues (aka: Task Queues) is to avoid doing a
resource-intensive task immediately and having to wait for it to complete. Instead
we schedule the task to be done later. We encapsulate a task as a message and
send it to a queue. A worker process running in the background will pop the tasks
and eventually execute the job. When you run many workers the tasks will be
shared between them.
This concept is especially useful in web applications where it's impossible to handle
a complex task during a short HTTP request window.
Preparation
In the previous part of this tutorial we sent a message containing "Hello World!".
Now we'll be sending strings that stand for complex tasks. We don't have a
real-world task, like images to be resized or pdf files to be rendered, so let's fake it
by just pretending we're busy - by using the
Thread.sleep()
function. We'll
take the number of dots in the string as its complexity; every dot will account for
one second of "work". For example, a fake task described by
Hello...
will take
three seconds.
We will slightly modify the Send.java code from our previous example, to allow
arbitrary messages to be sent from the command line. This program will schedule
tasks to our work queue, so let's name it
NewTask.java
:
String message = getMessage(argv);
channel.basicPublish("", "hello", null, message.getBytes());
System.out.println(" [x] Sent '" + message + "'");
剩余39页未读，继续阅读
happy366day
- 粉丝: 5
- 资源: 78
我的内容管理
展开
最新资源
- 岩石滑动与断层冲击地压：声发射特征分析
- 新时代煤炭工业八大战略新取向剖析
- 开采强度对华亭矿区冲击地压危险性的影响分析
- 新安煤矿探采对比：影响安全生产的关键因素与技术支撑
- 210MW循环流化床锅炉引风机变频改造优化与节能效果
- 浅埋煤层开采沉陷预测：方法应用与影响分析
- 优化巷道过陷落柱支护方案：数值模拟与现场试验
- 坚硬顶板定向断裂爆破技术：安全高效采煤新方案
- 北航2019算法课作业解析：投资策略与凸子多边形优化
- 断层破碎带垮冒下堆积体边界抗力分布关键影响因素
- 哈拉沟选煤厂优化末煤系统提高效率与处理能力
- 瓦斯涌出影响下采动煤体蠕变失稳研究
- 提升煤矿装载效率的可控箕斗定量装载设备设计
- 水分调控下烟煤瓦斯吸附特性对比研究
- 重介质悬浮液密度控制硬件设计与选型探讨
- 坚硬顶板巷道支护参数设计：现场测试与数值分析
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
