jfinal-zbus 正在参加 2020 年度 OSC 中国开源项目评选,请投票支持!
jfinal-zbus 在 2020 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
投票让它出道
已投票
授权协议 Apache
开发语言 Java
操作系统 跨平台
软件类型 开源软件
开发厂商
地区 国产
提 交 者 玛雅牛
适用人群 未知
收录时间 2015-08-06

软件简介

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来发送简单的消息。


展开阅读全文

代码

的 Gitee 指数为
超过 的项目

评论 (6)

加载中
项目介绍中建议添加点示范性代码,这样更有吸引力,先顶一个 #jfinal-zbus#
2015/08/07 18:00
回复
举报
玛雅大牛的新作,不顶不行! #jfinal-zbus#
2015/08/07 18:01
回复
举报
必须顶起啊!玛雅大牛 我爱你282828 #jfinal-zbus#
2015/08/19 08:03
回复
举报
因为只知道zbus是消息队列~那这不是应该是可以不同服务器通信的吗?在哪配置地址? #jfinal-zbus#
2015/08/22 10:53
回复
举报
我也是醉了,代码和上面的描述代码不一致。 #jfinal-zbus#
2016/08/17 11:08
回复
举报
没有加到maven么? 新版本什么时间出来呢? 主要增加的功能? #jfinal-zbus#
2016/08/26 11:27
回复
举报
更多评论
发表了资讯
2015/08/18 00:00

JFinal极简zbus插件 jfinal-zbus 3.1.0版发布

JFinal极简zbus插件 该插件具有以下特点: 1)简化设计,去掉了异步发送,仅支持同步发送。 2)信息发送/接收支持泛型,类型安全。 3)可直接发送/接收JFinal中特有的Model对象和Record对象。 更新说明: 1)修正api中的拼写错误: registMqMessageCallback -> registerMqMessageCallback registTopicMessageCallbac...

35
51
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
发表于服务端专区
2015/08/02 21:21

Zbus的JFinal插件实现第二版

Zbus的JFinal插件实现第二版

4
10
发表于服务端专区
2015/04/11 15:04

JFinal之JFinal学习日记

记录JFinal学习过程中遇到的问题、心得

1
1
发表了博客
10/03 10:05

jfinal(1)—jfinal-undertow 下开发 jfinal项目

1、创建标准的 maven web项目 没装maven和没创建maven web项目的可以看这三篇! maven安装 Eclipse和maven工具的集成 Eclipse使用maven创建web项目 2、添加 jfinal-undertow 与 jfinal 依赖 <dependency> <groupId>com.jfinal</groupId> <artifactId>jfinal-undertow</artifactId> <version>2.1</version> <...

0
0
发表于AI & 大数据专区
2015/03/19 10:51

JFinal源码走读_1_jfinal初始化

jfinal的入口 步进分析 jfinal核心初始化方法jfinalinit分析 ConfigconfigJFinaljfinalConfig分析 ConfigconfigJFinaljfinalConfig分析 startPlugins分析 url到action映射的核心实现 initHandler分析 initRender分析 renderFactoryinitconstants servletContext分析 initOreillyCos分析 initI18n分析 initTokenManager分...

2
6
发表于AI & 大数据专区
2015/01/19 12:08

也聊聊JFinal

技术小站: http://www.kiratechblog.com/ 最近给项目选型的时候,选了JFinal这套框架,开始的时候有些小伙伴会不理解,在Java的世界里面那么多的MVC框架,那么多的持久化框架,怎么就选了JFinal这玩意。 吐槽一下 这就不得不从比较正派的J2EE框架说起了(好吧。。。我是个经常不按照常理出牌的工程师),一般企业应用开...

2
1
发表了博客
2013/07/17 21:41

jfinal收集

jfinal demo修改 http://www.oschina.net/question/260040_45773 jfinal 输出json http://www.oschina.net/question/812908_72711

0
1
发表了博客
2012/07/17 09:40

JFinal 给力

在OSC社区 偶然机会接触到了JFinal,感觉零配置、路由模式、快速调试、轻量级代码等优点实在给力,主人的更新DEMO版本更是全面,为新人接触JFinal降低了台阶,上手很快。 8错的东东。近期抽出时间 上几个项目。 深入学习下。OL LET'S GO!

8
3
发表了博客
2019/07/31 11:57

JFinal教程

自学JFinal总结 前言:每次搭建ssm框架时,就像搬家一样,非常繁杂,并且还容易出错。正好了解到JFinal极简,无需配置即可使用,在这里记录下学习的过程。 感谢:非常感谢此网站发布的教程,非常详细,有兴趣的可以多看看,手把手教程了。。。。。https://www.jfinal.com/doc/1-3 开始正文吧! 一、搭建JFinal项目:   ...

0
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
发表了问答
2016/02/01 15:58

zbus rpc不支持com.jfinal.plugin.activerecord.Page类型

@JFinal @少帮主 你好,想跟你请教个问题: 尝试了一下rpc的直连,发现zbus不支持JFinal的com.jfinal.plugin.activerecord.Page类型。 BlogController setAttr("blogPage", blogService.paginate(getParaToInt(0, 1), 10)); render("blog.html"); BlogServiceImpl public Page<Blog> paginate(int pageNumber, int page...

1
0
发表了问答
2016/03/14 15:02

JFinal加入插件时,拒绝链接,请问怎么回事?

@玛雅牛 @JFinal 你好,想跟你请教个问题: // zbus消息插件 ZbusPlugin zp = new ZbusPlugin(); plugins.add(zp); zp.registerMqMsgHandler("MyStr", new TMsgHandler<String>() {   public void handle(String msg) {     System.out.println("AAA:" + msg);   }; }); [2016-03-14 14:44:52][ERROR][SelectorThread]Connec...

1
0
发表了问答
2015/09/06 11:41

zbus使用场景问题

@玛雅牛 你好,想跟你请教个问题: 看到你的jfinal-zbus插件,想问一下你使用zbus的场景是什么?能否举一些使用的例子,谢谢!

1
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
6 评论
67 收藏
分享
返回顶部
顶部