Tell us about your Moquette usage

[andsel]

Hi folks, I open this discussion to know from you, which is your experience with Moquette MQTT broker.
How do you use it, as standalone broker or inside a product? Tell us, if you can, what strengts you have discovered and which are the pain points or the things that can be improved.
A couple of existing feedbacks:

• Traffic lights in Hamburg: Moquette in action #719
• Made an App(Narada : MQTT Broker) using moquette for Android #684

I would love to know from the peoples that uses it, your stories.

[robinwu2008]

I use mqtt to push messages to the terminal so need mqtt server to support personalized authentication like reading the user's token from mysql or redis

[robinwu2008]

I also need to use mqtt as a im server, so I expect mqtt server to provide some interfaces for message persistence, offline messages, etc

[SpringStudent]

I use this project as a communication service for the RPC-MQTT middleware. In our IoT domain, the public server needs to invoke a specific method on a client within the local area network. In this case, Moquette acts as a data relay station for data forwarding.
here is an demo project https://github.com/SpringStudent/rpc-mqtt

[Lilithsy]

从上个月开始一直抛出这个错误是不是跟更新依赖有关呢03-27 11:06:49.421 ERROR[oup-6-4]broker.NewNettyMQTTHandler:Unexpected exception while processing MQTT message. Closing Netty channel. CId=null

java.net.SocketException: Connection reset
at sun.nio.ch.SocketChannelImpl.throwConnectionReset(SocketChannelImpl.java:394) ~[?:?]
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:426) ~[?:?]
at io.netty.buffer.PooledByteBuf.setBytes(PooledByteBuf.java:255) ~[netty-buffer-4.1.119.Final.jar!/:4.1.119.Final]
at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132) ~[netty-buffer-4.1.119.Final.jar!/:4.1.119.Final]
at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:356) ~[netty-transport-4.1.119.Final.jar!/:4.1.119.Final]
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:151) ~[netty-transport-4.1.119.Final.jar!/:4.1.119.Final]
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:796) ~[netty-transport-4.1.119.Final.jar!/:4.1.119.Final]
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:732) ~[netty-transport-4.1.119.Final.jar!/:4.1.119.Final]
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:658) ~[netty-transport-4.1.119.Final.jar!/:4.1.119.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) ~[netty-transport-4.1.119.Final.jar!/:4.1.119.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:998) ~[netty-common-4.1.119.Final.jar!/:4.1.119.Final]
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-common-4.1.119.Final.jar!/:4.1.119.Final]
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.1.119.Final.jar!/:4.1.119.Final]
at java.lang.Thread.run(Thread.java:833) [?:?]怎么解决这个问题

[andsel]

Hi @Lilithsy this discussion is to tell us your experience with Moquette and in which field/context you use it.
It's not intended for bug report, please file a new bug report under https://github.com/moquette-io/moquette/issues describing the problem you face in English please.

[Lilithsy]

Sent a question but did not reply, please reply. Thank you