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

Question

@玛雅牛 @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]Connection refused: no further information
java.net.ConnectException: Connection refused: no further information
	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:716)
	at org.zbus.net.core.SelectorThread.handleConnectEvent(SelectorThread.java:247)
	at org.zbus.net.core.SelectorThread.run(SelectorThread.java:121)
[2016-03-14 14:44:54][ERROR][Consumer]Session not registered yet:Session [remote=null, status=CLOSED, id=368fd7a3-e60f-473b-9ba0-5ead5dd7ec19]
java.io.IOException: Session not registered yet:Session [remote=null, status=CLOSED, id=368fd7a3-e60f-473b-9ba0-5ead5dd7ec19]
	at org.zbus.net.core.Session.write(Session.java:140)
	at org.zbus.net.core.Session.write(Session.java:135)
	at org.zbus.net.InvokingClient.invokeSync(InvokingClient.java:98)
	at org.zbus.mq.Consumer.recv(Consumer.java:75)
	at org.zbus.mq.Consumer$1.run(Consumer.java:142)
	at java.lang.Thread.run(Thread.java:745)
[2016-03-14 14:44:55][ERROR][SelectorThread]Connection refused: no further information
java.net.ConnectException: Connection refused: no further information
	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:716)
	at org.zbus.net.core.SelectorThread.handleConnectEvent(SelectorThread.java:247)
	at org.zbus.net.core.SelectorThread.run(SelectorThread.java:121)
[2016-03-14 14:44:57][ERROR][Consumer]Session not registered yet:Session [remote=null, status=CLOSED, id=be307bd3-4c98-43b1-b71a-6d5efa69a8dd]
java.io.IOException: Session not registered yet:Session [remote=null, status=CLOSED, id=be307bd3-4c98-43b1-b71a-6d5efa69a8dd]
	at org.zbus.net.core.Session.write(Session.java:140)
	at org.zbus.net.core.Session.write(Session.java:135)
	at org.zbus.net.InvokingClient.invokeSync(InvokingClient.java:98)
	at org.zbus.mq.Consumer.recv(Consumer.java:75)
	at org.zbus.mq.Consumer$1.run(Consumer.java:142)
	at java.lang.Thread.run(Thread.java:745)
[2016-03-14 14:44:58][ERROR][SelectorThread]Connection refused: no further information
java.net.ConnectException: Connection refused: no further information
	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:716)
	at org.zbus.net.core.SelectorThread.handleConnectEvent(SelectorThread.java:247)
	at org.zbus.net.core.SelectorThread.run(SelectorThread.java:121)
[2016-03-14 14:45:00][ERROR][Consumer]Session not registered yet:Session [remote=null, status=CLOSED, id=824d5869-006d-4909-9faf-6702b715b256]
java.io.IOException: Session not registered yet:Session [remote=null, status=CLOSED, id=824d5869-006d-4909-9faf-6702b715b256]
	at org.zbus.net.core.Session.write(Session.java:140)
	at org.zbus.net.core.Session.write(Session.java:135)
	at org.zbus.net.InvokingClient.invokeSync(InvokingClient.java:98)
	at org.zbus.mq.Consumer.recv(Consumer.java:75)
	at org.zbus.mq.Consumer$1.run(Consumer.java:142)
	at java.lang.Thread.run(Thread.java:745)

Answer 1

本地zbus 服务没有启动？ZbusPlugin zp =new ZbusPlugin()默认链接的zbus服务器地址为：127.0.0.1:15555，若使用其它地址，需要ZbusPlugin zp =new ZbusPlugin(“192.168.1.2:15555”)，在构造函数中指定地址参数