jmqtt
jmqtt copied to clipboard
Cicizz
A MQTT broker,implemented by java and netty,support persistence and cluster
系统：CentsOS 7,JDK8 描述：把jmqtt-distribution/target/jmqtt拷贝VM, 运行jmqtt-distribution/target/jmqtt/jmqttstart，出现以下异常，但是可以启动，请问怎么修改这个呢？在MAC中没有此异常。 Unable to load the library 'netty_transport_native_epoll_x86_64', trying other loading mechanism. java.lang.UnsatisfiedLinkError: no netty_transport_native_epoll_x86_64 in java.library.path at java.lang.ClassLoader.loadLibrary(ClassLoader.java:1860) at java.lang.Runtime.loadLibrary0(Runtime.java:870) at java.lang.System.loadLibrary(System.java:1122) at io.netty.util.internal.NativeLibraryUtil.loadLibrary(NativeLibraryUtil.java:38) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)...
大佬早上好, 同一个Client在不同的Broker进行Connect时, 是不是应该支持互踢功能, 该功能是不是预备在org.jmqtt.broker.processor.ConnectProcessor.void newClientNotify(ClientSession clientSession) 做出集群各个broker通知进行维护?
请教一下， 以下是我debug过程中的分析， 请指正是否正确？ ConnectProcessor processRequest(ChannelHandlerContext ctx, MqttMessage mqttMessage) 中保存will message 到 willMessageStore，但是没有地方保存在will topic 到subscriptionMatcher中。 所以在发送will message 的时候， subscriptionMatcher match 不到对应的will topic的Subscription。从而导致will message 发送不成功 Set subscriptions = subscriptionMatcher.match((String) message.getHeader(MessageHeader.TOPIC));
ConnectProcessor.java的createNewClientSession在subscriptionStore.clearSubscription时是不是也该subscriptionMatcher.unSubscribe，否则subscriptionMatcher与subscriptionStore的订阅不一致了。
假设192.168.1.1 , 192.168.1.2 ,192.168.1.3 192.168.1.1 配置cluster currentNodeIp="192.168.1.1" nodeName="node_1" groupServerPort=8880 # init group nodes,ip1:port1;ip2:port2 groupNodes="192.168.1.1:8080;192.168.1.2:8080;192.168.1.3:8080" 这样配置是否有无，另外cluster有无消息备份及故障转移特性？
