x/beanstalkdTube组件：v0.29.0+ Beanstalkd生产端，支持以下操作Put、PeekReady、PeekDelayed、PeekBuried、Kick、Stat、Pause。

需要额外引入扩展库：rulego-components (opens new window) 需要配置组件连接复用 (opens new window),不同节点之间通过组件连接复用保持客户端实例一致（Beanstalkd客户端订阅消息后，会锁死当前客户端，其他客户端无法对消息操作）

配置

字段	类型	说明	默认值
server	string	Beanstalkd服务器地址	127.0.0.1:11300
tube	string	必填，Tube名称允许使用 ${} 占位符变量	default
cmd	string	必填，命令名称，支持Put、PeekReady、PeekDelayed、PeekBuried、Kick、Stat、Pause	Stat
body	string	body消息内容，允许使用 ${} 占位符变量,Put命令参数
pri	string	优先级，允许使用 ${} 占位符变量,Put命令参数
delay	string	延迟时间，允许使用 ${} 占位符变量,Put命令参数
ttr	string	Job最大执行秒数, 允许使用 ${} 占位符变量,Put命令参数
kickBound	string	Kick命令参数bound 允许使用 ${} 占位符变量
pauseTime	string	Pause命令参数time 允许使用 ${} 占位符变量

配置示例

{
"ruleChain": {
"id": "f5G9y8GzpgDY",
"name": "Beanstalkd Node 测试",
"debugMode": false,
"root": true,
"disabled": false,
"additionalInfo": {
"createTime": "2025/01/15 21:50:47",
"description": "",
"layoutX": "700",
"layoutY": "100",
"message": "the rule chain has been disabled",
"updateTime": "2025/01/17 14:31:16",
"username": "admin"
}
},
"metadata": {
"endpoints": [
{
"id": "node_2",
"additionalInfo": {
"layoutX": 450,
"layoutY": 160
},
"type": "endpoint/http",
"name": "API",
"debugMode": false,
"configuration": {
"allowCors": true,
"server": ":6333"
},
"processors": null,
"routers": [
{
"id": "KOUXvKLg1Ml2",
"params": [
"POST"
],
"from": {
"path": "/msg/add",
"configuration": null,
"processors": [
"setJsonDataType"
]
},
"to": {
"path": "f5G9y8GzpgDY:node_4",
"configuration": null,
"wait": true,
"processors": [
"responseToBody",
"metadataToHeaders"
]
}
},
{
"id": "Ud6fjHltHyKg",
"params": [
"POST"
],
"from": {
"path": "/msg/del",
"configuration": null,
"processors": [
"setJsonDataType"
]
},
"to": {
"path": "f5G9y8GzpgDY:node_8",
"configuration": null,
"wait": true,
"processors": [
"responseToBody",
"metadataToHeaders"
]
}
},
{
"id": "HlgiXu67EWBX",
"params": [
"POST"
],
"from": {
"path": "/msg/release",
"configuration": null,
"processors": [
"setJsonDataType"
]
},
"to": {
"path": "f5G9y8GzpgDY:node_15",
"configuration": null,
"wait": true,
"processors": [
"responseToBody"
]
}
}
]
}
],
"nodes": [
{
"id": "node_4",
"additionalInfo": {
"layoutX": 950,
"layoutY": 160
},
"type": "x/beanstalkdTube",
"name": "Put",
"debugMode": true,
"configuration": {
"body": "${msg.body}",
"cmd": "Put",
"putBody": "${msg.body}",
"server": "ref://local_beanstalkdTube",
"tube": "${msg.tube}"
}
},
{
"id": "node_8",
"additionalInfo": {
"layoutX": 900,
"layoutY": 400
},
"type": "x/beanstalkdWorker",
"name": "Del",
"debugMode": true,
"configuration": {
"cmd": "Delete",
"jobId": "${msg.id}",
"server": "ref://local_beanstalkdWorker",
"tube": "${msg.tube}"
}
},
{
"id": "node_13",
"additionalInfo": {
"layoutX": 850,
"layoutY": 550
},
"type": "x/beanstalkdWorker",
"name": "Release",
"debugMode": true,
"configuration": {
"cmd": "Release",
"jobId": "${id}",
"server": "ref://local_beanstalkdWorker",
"tube": "${tube}"
}
},
{
"id": "node_15",
"additionalInfo": {
"layoutX": 500,
"layoutY": 530
},
"type": "x/beanstalkdWorker",
"name": "ReserveJob",
"debugMode": true,
"configuration": {
"cmd": "ReserveJob",
"jobId": "${msg.id}",
"server": "ref://local_beanstalkdWorker",
"tube": "${msg.tube}"
}
}
],
"connections": [
{
"fromId": "node_15",
"toId": "node_13",
"type": "Success"
}
]
}
}

Relation Type

• Success: 执行成功，把消息发送到Success链
• Failure: 执行失败，把消息发送到Failure链

执行结果

参考Beanstkd执行命令返回值，被转换为 RuleMsg 格式并发送到规则链：

• data：消息内容
• dataType：JSON
• type：默认为空
• metadata：消息元数据，包括 id、tube 等信息