yoyo中间件是某公司的消息转发配件,其在底层构建了一个通信网络,能够完成无线和有线的快速组网(类似于MQTT? (谨慎)带有个人观点)。
首先完成虚拟机安装配置部分:
在Linux虚拟机上进行安装部署,具体步骤参考安装说明书((bitsflow)官方)有:
①准备bitsflow安装环境
②agent.xml文件配置:将192.168.245.129(虚拟机1)以及192.168.245.130(虚拟机2)设置为约会节点,192.168.245.128(虚拟机0)完成bitsflow底层组网。具体配置以虚拟机0为例:
③ 启动agent服务
根据虚拟机需求选择发送和监听函数:
- 功能的实现:
虚拟机1为消息发送者,虚拟机0,2为消息订阅者,其中虚拟机2为中间件。通过对虚拟机0进行参数修改可以禁止其接收虚拟机1发送的消息;虚拟机2接收到虚拟机1发送的消息并修改后将其发送给虚拟机0,起到中间件作用。
虚拟机1:作为消息发送者只需要启动agent并运行发送函数即可
但使用系统自带的函数就会导致虚拟机2(中间件)无法同时实现接收和转发。因此需要根据bitsflow说明编写程序以达到实现既能发送也能接收的功能。
为此首先要编写发送消息的代码:
import subprocess
def execute_commands():
cd_command = 'cd /home && '
ping_command = 'ping www.baidu.com'
command = cd_command + ping_command
process = subprocess.Popen(command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
for line in iter(process.stdout.readline, b''):
print(line.rstrip())
process.wait()
execute_commands()
对代码进行修改后:
import subprocess
import os
def execute_commands():
ping_command = "cd /home/user/bitsflow/bitsflown/ && ./bin/yoyo_send -agent 192.168.245.129:1234 -service 5678 \"Test.1\" \”test\”"
command =ping_command
process = subprocess.Popen(command, shell=True, stdout=subprocess. PIPE, stderr=subprocess.STDOUT
for line in iter(process.stdout.readline, b''):
print(line.rstrip().decode())
process.wait()
execute_commands()
虚拟机2:
使用python编写程序时:
发生错误:找不到对应的文件或目录
此问题经过长时间思考仍无法解决。
解决了,重新理一下思路
实验步骤:
- 接收机配置情况:
① 进入终端,打开bitsflow软件
② 修改agent.xml配置文件
Network-interface : 修改为本机的ip地址
Rendezvous-Agent(约会节点):修改为另外两个主机的ip
Is-Rendezvous-Agent:本机并非约会节点
③ 开启bitsflow的agent代理服务
开启监听服务。监听主题为“Test.1” (出现warning警告为正常现象)
④ 关闭防火墙并禁止接收发送机ip
- 发送机
① 进入终端,打开bitsflow软件
② 修改agent.xml配置文件
③ 开启bitsflow 的agent代理功能
④ 关闭防火墙
⑤ 开启发送程序,发送主题为“Test.1” 内容为”skkkyu”的消息
- 中间件配置情况:
① 进入终端,打开bitsflow软件
② 修改agent.xml配置文件
① 开启bitsflow 的agent代理功能(此步骤与接收机操作流程相同,但不需要使用yoyo-listen函数)
使用python3 1.py 执行编写好的转发功能代码
中间件开始监听发送机的消息
若发送机发送 “skkkyu”, 中间件将会接收到对应消息并转发给接收机
接收机接收到消息:
- 验证发送机发送的消息不能直接到达接收机
① 关闭中间件程序
② 发送机发送消息 “fasong”
③ 查看接收机是否收到消息
- 问题
部分配置需要根据环境进行手动修改,鲁棒性不好,并且由于bitflow的软件问题,部分消息的转发时间与接受时间对不上,这有可能造成处理代码的错误,中间件程序有时出现运行出错的情况,需要重复开启关闭,此外,还存在消息转发格式的修改和配置问题,需要根据实际环境调试。 - 总结
在我们自定义环境下的现有转发功能基本实现,可以初步的用于演示,但是仍然存在多种问题急需完善,其稳定性有待进一步增强。
代码截图(由于其小众性和正确性,目前不给出直接的代码,但是思路正确)