运行 beantalkd 作业从 php 管子放到 fivebeans worker
run beanstalkd job put from php tube to fivebeans worker
你好,有一个 php 应用程序,我通过 https://github.com/pda/pheanstalk/
在其中放置了一些工作
$pheanstalk
->useTube('testtube')
->put(json_encode(array('hello' => 'mdjaman')));
那我想用nodejs https://www.npmjs.com/package/fivebeans worker来处理作业;不幸的是,我在 fivebeans 的伟大文档中遗漏了一些东西
有人能指出我正确的轨道吗?这是我的 js 文件
var Beanworker = require('fivebeans').worker;
var options =
{
id: 'worker_4',
host: '0.0.0.0',
port: 13000,
handlers:
{
type: 'emitkeys'
},
ignoreDefault: true
}
var worker = new Beanworker(options);
worker.start(['testtube']);
worker.on('info', function(message) {
console.log('worker started with msg ' + message);
});
- 说 "It Doesn't Work" - 没有帮助。
- Beanstalkd 通常在端口 11300 上启动,而不是 13000
你需要
$tt["payload"] = array('hello' => 'mdjaman');
$tt ["type"]="testtube";
$js = json_encode($tt);
$tid = $beans->useTube('testtube')->put($js);
最终使用另一种实现方式nodestalker
你好,有一个 php 应用程序,我通过 https://github.com/pda/pheanstalk/
在其中放置了一些工作$pheanstalk
->useTube('testtube')
->put(json_encode(array('hello' => 'mdjaman')));
那我想用nodejs https://www.npmjs.com/package/fivebeans worker来处理作业;不幸的是,我在 fivebeans 的伟大文档中遗漏了一些东西 有人能指出我正确的轨道吗?这是我的 js 文件
var Beanworker = require('fivebeans').worker;
var options =
{
id: 'worker_4',
host: '0.0.0.0',
port: 13000,
handlers:
{
type: 'emitkeys'
},
ignoreDefault: true
}
var worker = new Beanworker(options);
worker.start(['testtube']);
worker.on('info', function(message) {
console.log('worker started with msg ' + message);
});
- 说 "It Doesn't Work" - 没有帮助。
- Beanstalkd 通常在端口 11300 上启动,而不是 13000
你需要
$tt["payload"] = array('hello' => 'mdjaman');
$tt ["type"]="testtube";
$js = json_encode($tt);
$tid = $beans->useTube('testtube')->put($js);
最终使用另一种实现方式nodestalker