- 授权协议: Apache
- 开发语言: Java
- 操作系统: 跨平台
- 软件首页: https://git.oschina.net/myaniu/jfinal-zbus
- 软件文档: https://git.oschina.net/myaniu/jfinal-zbus
软件介绍
JFinal极简zbus插件,
该插件具有以下特点:
1)简化设计,去掉了异步发送,仅支持同步发送。
2)信息发送/接收支持泛型,类型安全。
3)可直接发送/接收JFinal中特有的Model对象和Record对象。
导入dist目录下的jfinal-zbus-3.1.0.jar
同时还需要导入zbus,znet,fastjson,jfinal等jar包
配置代码如下:
//初始化zbus插件 ZbusPlugin zp = new ZbusPlugin(); //创建一个MQ zp.createMq("MyMQ"); //创建一个Topic(zbus中topic必须属于某个队列,所以第一个参数是mq名,第二个参数是topic名) zp.createTopic("Topic", "Check"); //注册MQ的消息到达(收到消息)回调泛型(Dict类型,Dict继承子Model)接口。 zp.registerMqMessageCallback("MyMQ", new TMessageCallback<Dict>(){ @Override public void onMessage(Dict msg) { LOG.info("receive from MyMQ: key=" + msg.getStr("key") + ",value=" + msg.getStr("value")); } }); //注册Topic的消息到达(收到消息)回调泛型(String类型)接口。 zp.registerTopicMessageCallback("Topic", "Check", new TMessageCallback<String>(){ @Override public void onMessage(String msg) { LOG.info("receive from Topic.Check: msg=" + msg); } }); //添加插件 me.add(zp);
//初始化一个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.send(dict); //初始化一个Topic泛型(String类型)发送器,构造函数参数为,MQ名,Topic名 Sender<String> topicSender = new TopicSender<String>("Topic", "Check"); //发送对象到topic topicSender.send("这时一个订阅消息");
使用时,可在需要发送的类里定义一个特定类型的发送器。建议发送器的类型不要太复杂。只通过zbus来发送简单的消息。
产品经理全栈运营实战笔记
林俊宇 / 化学工业出版社 / 49.8元
本书凝结作者多年的产品运营经验,读者会看到很多创业公司做运营的经验,书中列举了几十个互联网产品的运营案例去解析如何真正做好一个产品的冷启动到发展期再到平稳期。本书主要分为六篇:互联网运营的全面貌;我的运营生涯;后产品时代的运营之道;揭秘刷屏事件的背后运营;技能学习;深度思考。本书有很多关于产品运营的基础知识,会帮助你做好、做透。而且将理论和作者自己的案例以及其他人的运营案例结合起来,会让读者更容易......一起来看看 《产品经理全栈运营实战笔记》 这本书的介绍吧!