yoyo中间件（bitsflow）的使用及消息控制-全

yoyo中间件是某公司的消息转发配件，其在底层构建了一个通信网络，能够完成无线和有线的快速组网（类似于MQTT? （谨慎）带有个人观点）。

首先完成虚拟机安装配置部分：
在Linux虚拟机上进行安装部署，具体步骤参考安装说明书（（bitsflow）官方）有：
①准备bitsflow安装环境

image.png

②agent.xml文件配置：将192.168.245.129（虚拟机1）以及192.168.245.130（虚拟机2）设置为约会节点，192.168.245.128（虚拟机0）完成bitsflow底层组网。具体配置以虚拟机0为例：

image.png

③ 启动agent服务

image.png

根据虚拟机需求选择发送和监听函数：

image.png

功能的实现：

虚拟机1为消息发送者，虚拟机0，2为消息订阅者，其中虚拟机2为中间件。通过对虚拟机0进行参数修改可以禁止其接收虚拟机1发送的消息；虚拟机2接收到虚拟机1发送的消息并修改后将其发送给虚拟机0，起到中间件作用。

虚拟机1：作为消息发送者只需要启动agent并运行发送函数即可

image.png

但使用系统自带的函数就会导致虚拟机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()

image.png

对代码进行修改后：

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()

image.png

虚拟机2：

使用python编写程序时：
发生错误：找不到对应的文件或目录

image.png

此问题经过长时间思考仍无法解决。

解决了，重新理一下思路

实验步骤：

接收机配置情况：

① 进入终端，打开bitsflow软件

② 修改agent.xml配置文件

Network-interface : 修改为本机的ip地址

image.png

Rendezvous-Agent（约会节点）：修改为另外两个主机的ip
Is-Rendezvous-Agent：本机并非约会节点

③ 开启bitsflow的agent代理服务

image.png

开启监听服务。监听主题为“Test.1” (出现warning警告为正常现象)

④ 关闭防火墙并禁止接收发送机ip

image.png

发送机

① 进入终端，打开bitsflow软件
② 修改agent.xml配置文件

image.png

③ 开启bitsflow 的agent代理功能

image.png

④ 关闭防火墙

image.png

⑤ 开启发送程序，发送主题为“Test.1” 内容为”skkkyu”的消息

image.png

中间件配置情况：

① 进入终端，打开bitsflow软件

② 修改agent.xml配置文件

image.png

① 开启bitsflow 的agent代理功能（此步骤与接收机操作流程相同，但不需要使用yoyo-listen函数）

使用python3 1.py 执行编写好的转发功能代码

中间件开始监听发送机的消息

image.png

若发送机发送 “skkkyu”, 中间件将会接收到对应消息并转发给接收机

image.png

接收机接收到消息：

image.png

验证发送机发送的消息不能直接到达接收机
① 关闭中间件程序

image.png

② 发送机发送消息 “fasong”

image.png

③ 查看接收机是否收到消息

image.png

问题
部分配置需要根据环境进行手动修改，鲁棒性不好，并且由于bitflow的软件问题，部分消息的转发时间与接受时间对不上，这有可能造成处理代码的错误，中间件程序有时出现运行出错的情况，需要重复开启关闭，此外，还存在消息转发格式的修改和配置问题，需要根据实际环境调试。
总结
在我们自定义环境下的现有转发功能基本实现，可以初步的用于演示，但是仍然存在多种问题急需完善，其稳定性有待进一步增强。

代码截图（由于其小众性和正确性，目前不给出直接的代码，但是思路正确）

image.png