普通话题不需要额外创建,消息的发布直接根据 AmopMsgOut 的setTopic 方法设置 本次消息发布的 topic
本次示例为 Java SDK 的使用测试,且使用代码完成 Topic 的创建以及订阅
1、订阅话题
1.1 创建一个订阅测试类 SubScribeTest
1.2 加载 toml 配置文件
注:本示例不通过在 *.toml 配置文件中配置AMOP项来实现 Topic 的创建以及订阅,故可以直接使用源码的参考配置文件 config-example.toml
String configFile = SubScribe.class.getClassLoader().getResource("config-subScribe.toml").getPath();
1.3 初始化BcosSDK,并获取Amop的实例
BcosSDK sdk = BcosSDK.build(configFile);
Amop amop = sdk.getAmop();
1.4 重写接收到消息后的回调函数
AmopCallback cb = new AmopCallback() {
@Override
public byte[] receiveAmopMsg(AmopMsgIn msg) {
// 收到消息后的处理逻辑。
}
};
1.5 发起订阅
amop.subscribeTopic("testTopic", cb);
2、发送消息
2.1 创建一个发布测试类 PublishTest
2.2 加载 toml 配置文件
String configFile = Publish.class.getClassLoader().getResource("config-publish.toml").getPath();
2.3 初始化BcosSDK,并获取Amop的实例
ConfigOption configOption = Config.load(configFile);
BcosSDK sdk = new BcosSDK(configOption);
Amop amop = sdk.getAmop();
2.4 配置 AmopMsgOut
AmopMsgOut out = new AmopMsgOut();
out.setTopic("testTopic");
out.setType(TopicType.NORMAL_TOPIC);
out.setContent("吃饭了吗".getBytes());
out.setTimeout(6000);
2.5 设置订阅方响应后的回调函数
AmopResponseCallback cb = new AmopResponseCallback() {
@Override
public void onResponse(AmopResponse amopResponse) {
//响应后的逻辑处理代码编写
}
};
2.6 向指定 topic 的订阅方发送消息(单播)
amop.sendAmopMsg(out, cb);
2.7 向指定 topic 的订阅方发送消息 (广播)
amop.broadcastAmopMsg(out);