ZBus 6.2.0 初体验

一直在做技术选型，Kafka还要学习scala,蛋疼，MetaQ太重，

朋友推荐HTTPSQS,自己看了几个MQ,最终决定引入轻量级的ZBus.

---这里的版本号是 6.2.0

http://git.oschina.net/rushmore/zbus/tree/6.2.0-release/

下载后，解压缩，将文件夹上传到linux.

如何启动二进制版本的ZBus?

cd /root/zbus-6.2.0-release/zbus/zbus-dist

./zbus.sh
就可以启动了(如果没启动，需要修改zbus.sh里的JAVA_HOME的值)

启动结果如图：

可以看到监听端口为 15555.

查看进程

可以看到主类为

 org.zbus.mq.server.MqServer

下面就需要分析这个类。

首先把代码加载到eclipse, 这是为了编译成class文件，此部分忽略。

如果碰到sun.misc.Cleaner cleaner = (sun.misc.Cleaner) getCleanerMethod.invoke(writeIndex);

这类的问题，：

引入完毕后，在eclipse里是酱紫的。

然后准备放到linux里。

下面准备源码debug环境。

--------------------------------------------------机器的machine_8.6

具体细节略去。

[[email protected] zbus-6.2.0-debug]# cd $ZBUS_HOME
[[email protected] zbus-6.2.0-debug]# jdb org.zbus.mq.server.MqServer
Initializing jdb ...
> stop in org.zbus.mq.server.MqServer.main
Deferring breakpoint org.zbus.mq.server.MqServer.main.
It will be set after the class is loaded.
> run
run org.zbus.mq.server.MqServer
Set uncaught java.lang.Throwable
Set deferred uncaught java.lang.Throwable
> 
VM Started: Set deferred breakpoint org.zbus.mq.server.MqServer.main
Breakpoint hit: "thread=main", org.zbus.mq.server.MqServer.main(), line=161 bci=0
161      MqServerConfig config = new MqServerConfig();
main[1]

好，可以开始愉快的玩耍了。。。