码云 IDEA 插件最新版本发布,支持 Pull Request

wanglaoju / jfinal-zbusApache-2.0

Watch 1 Star 0 Fork 40
forked from 玛雅牛 / jfinal-zbus 
加入碼雲
與超過 200 萬 開發者一起發現、參與優秀開源項目,私有倉庫也完全免費 :)
免費加入
zbus的jfinal插件 展開 收起

李飞 最後提交於 更新文档
取消
提示: 由於 Git 不支持空文件夾,創建文件夾後會生成空的 .keep 文件
Loading...
README.md

jfinal-zbus插件

项目依赖:jfina 2.2 ,zbus, fastjson , reflections,详见pom.xml文件

更新说明:

1)发送接受全部泛型化,更容易写出类型安全,高质量的代码。

2)支持直接发送JFinal中的Model,Record对象。

3)简化设计,不支持异步消息,只支持同步消息。

4)建议仅发送简单对象,类似List<Map<String,Model>>的复杂对象暂不支持。

使用方法: 在JFinal的Config配置文件中配置

//初始化zbus插件
String brokerAddress = "127.0.0.1:155555";
String scanRootPackage = "com.wellbole";
ZbusPlugin zbusPlugin = new ZbusPlugin(brokerAddress,scanRootPackage);
me.add(zbusPlugin);

在其他地方,通过Zbus来发送消息。

//初始化一个MQ泛型(Dict类型,Dict继承子Model)发送器,构造函数参数为MQ名
Sender<Dict> mqSender = new MqSender<Dict>("MyMQ");
Dict dict = new Dict();
dict.setId(1L);
dict.set("key", "key"+1);
dict.set("value", "value"+1);
//同步发送对象到MQ
mqSender.sendSync(dict);
//sendAsync
//异步发送对象到MQ
//mqSender.sendAsync(dict);

//初始化一个Topic泛型(String类型)发送器,构造函数参数为,MQ名,Topic名
Sender<String> topicSender = new TopicSender<String>("Topic", "Check");
//同步发送对象到topic
topicSender.sendSync("这时一个订阅消息");
//异步发送对象到topic
//topicSender.sendAsync("这时一个订阅消息");

//初始化一个Event泛型(String类型)发送器,内部实现是一个topic的变种,全局共用一个mq,topic就是类型名
Sender<String> eventSender = new EventSender<String>();

接收zbus传送的消息

@Mq("MQ-Str")
@Topic(mq="Topic",topic="Check")
@Event
@Handler
public class TestMsgHandler extends TMsgHandler<String> {
    private static final Log LOG = Log.getLog(TestMsgHandler.class);
    @Override
    public void handle(String msg) {
        LOG.info("received:msg="+msg);
    }
}

點評 ( 0 )

你可以在登錄後,發表評論

搜索幫助