MQTT hängt sich auf

Romel · Beitrag von **Romel** » 23. Aug 2020 23:23

Hallo ,

Ich hab seit kurzen laufend das Problem das sich mein MQTT Broker aufhängt.

das Log schreibt ununterbrochen diesen Eintrag;

Code: Alles auswählen

2020-08-23 22:52:29.638 [ERROR] [.moquette.broker.NewNettyMQTTHandler] - Error processing protocol message: SUBSCRIBE

java.lang.IllegalArgumentException: Could not deserialize [-84, -19, 0, 5, 115, 114, 0, 45, 105, 111, 46, 109, 111, 113, 117, 101, 116, 116, 101, 46, 98, 114, 111, 107, 101, 114, 46, 115, 117, 98, 115, 99, 114, 105, 112, 116, 105, 111, 110, 115, 46, 83, 117, 98, 115, 99, 114, 105, 112, 116, 105, 111, 110, -47, 11, -117, 54, 80, -6, 26, -58, 2, 0, 3, 76, 0, 8, 99, 108, 105, 101, 110, 116, 73, 100, 116, 0, 18, 76, 106, 97, 118, 97, 47, 108, 97, 110, 103, 47, 83, 116, 114, 105, 110, 103, 59, 76, 0, 12, 114, 101, 113, 117, 101, 115, 116, 101, 100, 81, 111, 115, 116, 0, 37, 76, 105, 111, 47, 110, 101, 116, 116, 121, 47, 104, 97, 110, 100, 108, 101, 114, 47, 99, 111, 100, 101, 99, 47, 109, 113, 116, 116, 47, 77, 113, 116, 116, 81, 111, 83, 59, 76, 0, 11, 116, 111, 112, 105, 99, 70, 105, 108, 116, 101, 114, 116, 0, 40, 76, 105, 111, 47, 109, 111, 113, 117, 101, 116, 116, 101, 47, 98, 114, 111, 107, 101, 114, 47, 115, 117, 98, 115, 99, 114, 105, 112, 116, 105, 111, 110, 115, 47, 84, 111, 112, 105, 99, 59, 120, 112, 116, 0, 12, 83, 99, 104, 97, 108, 1... [1.4.199/0]

	at org.h2.mvstore.DataUtils.newIllegalArgumentException(DataUtils.java:857) ~[bundleFile:1.4.199]

	at org.h2.mvstore.type.ObjectDataType.deserialize(ObjectDataType.java:376) ~[bundleFile:1.4.199]

	at org.h2.mvstore.type.ObjectDataType$SerializedObjectType.read(ObjectDataType.java:1547) ~[bundleFile:1.4.199]

	at org.h2.mvstore.type.ObjectDataType.read(ObjectDataType.java:231) ~[bundleFile:1.4.199]

	at org.h2.mvstore.type.ObjectDataType.read(ObjectDataType.java:114) ~[bundleFile:1.4.199]

	at org.h2.mvstore.Page$Leaf.readPayLoad(Page.java:1551) ~[bundleFile:1.4.199]

	at org.h2.mvstore.Page.read(Page.java:695) ~[bundleFile:1.4.199]

	at org.h2.mvstore.Page.read(Page.java:238) ~[bundleFile:1.4.199]

	at org.h2.mvstore.MVStore.readPage(MVStore.java:2187) ~[bundleFile:1.4.199]

	at org.h2.mvstore.MVMap.readPage(MVMap.java:554) ~[bundleFile:1.4.199]

	at org.h2.mvstore.Page$NonLeaf.getChildPage(Page.java:1086) ~[bundleFile:1.4.199]

	at org.h2.mvstore.MVMap.traverseDown(MVMap.java:1877) ~[bundleFile:1.4.199]

	at org.h2.mvstore.MVMap.operate(MVMap.java:1664) ~[bundleFile:1.4.199]

	at org.h2.mvstore.MVMap.put(MVMap.java:151) ~[bundleFile:1.4.199]

	at io.moquette.persistence.H2SubscriptionsRepository.addNewSubscription(H2SubscriptionsRepository.java:41) ~[bundleFile:?]

	at io.moquette.broker.subscriptions.CTrieSubscriptionDirectory.add(CTrieSubscriptionDirectory.java:88) ~[bundleFile:?]

	at io.moquette.broker.PostOffice.subscribeClientToTopics(PostOffice.java:81) ~[bundleFile:?]

	at io.moquette.broker.MQTTConnection.processSubscribe(MQTTConnection.java:307) ~[bundleFile:?]

	at io.moquette.broker.MQTTConnection.handleMessage(MQTTConnection.java:71) ~[bundleFile:?]

	at io.moquette.broker.NewNettyMQTTHandler.channelRead(NewNettyMQTTHandler.java:58) [bundleFile:?]

	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352) [bundleFile:4.1.42.Final]

	at io.moquette.broker.metrics.MQTTMessageLogger.channelRead(MQTTMessageLogger.java:46) [bundleFile:?]

	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352) [bundleFile:4.1.42.Final]

	at io.moquette.broker.metrics.MessageMetricsHandler.channelRead(MessageMetricsHandler.java:50) [bundleFile:?]

	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352) [bundleFile:4.1.42.Final]

	at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:328) [bundleFile:4.1.42.Final]

	at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:302) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352) [bundleFile:4.1.42.Final]

	at io.moquette.broker.metrics.BytesMetricsHandler.channelRead(BytesMetricsHandler.java:51) [bundleFile:?]

	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352) [bundleFile:4.1.42.Final]

	at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:287) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352) [bundleFile:4.1.42.Final]

	at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1422) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374) [bundleFile:4.1.42.Final]

	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360) [bundleFile:4.1.42.Final]

	at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:931) [bundleFile:4.1.42.Final]

	at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163) [bundleFile:4.1.42.Final]

	at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:700) [bundleFile:4.1.42.Final]

Das System läuft eigentlich ganz ruhig. Aber plötzlich kommt dieser Fehler und alles wird blockiert. Ich hab schon in anderen Foren gelesen, daß das mit dem "Embedded MQTT" Broker zu tun hat.

Hat jemand eine Idee oder vielleicht gibt es schon eine Lösung ?

Vielen Dank

peter-pan · Beitrag von **peter-pan** » 24. Aug 2020 09:24

Hast du es schon mal mit Mosquitto probiert ?

udo1toni · Beitrag von **udo1toni** » 24. Aug 2020 09:43

Es ist ja ziemlich offensichtlich, dass Moquette sich da an einem Datenpaket verschluckt. Du müsstest also versuchen, herauszufinden, welches Gerät da Schmonsens sendet

Da Moquette in der zur Zeit integrierten Form nicht mehr aktiv weiterentwickelt wird, wäre es das Einfachste, Moquette zu deinstallieren und mosquitto zu installieren.
Falls Du openHABian nutzt, geht das direkt aus openhabian-config heraus. Eine eventuell auftauchende Warnmeldung kannst Du getrst ignorieren, solange Du Moquette bereits deinstalliert hast (kann aber sein, dass die Meldung inzwischen inhaltlich korrigiert wurde und nicht länger missverständlich ist).

Romel · Beitrag von **Romel** » 24. Aug 2020 10:13

Danke für die schnelle Antwort.
Sowas hab ich mir schon gedacht.
Wie deinstalliere ich den Moquette Broker ?

Danke

Romel · Beitrag von **Romel** » 24. Aug 2020 10:23

Habs schon geschafft.
Hab einfach den Mosquitto installiert und ein neues Thing erstellt. Dann die Bridge bei den Things neu setzen. Fertig.

udo1toni · Beitrag von **udo1toni** » 24. Aug 2020 10:47

Ich hoffe mal, Du hast Moquette auch deinstaliert bekommen (Paper UI->Addons->Misc->Embedded MQTT Broker->uninstall

Romel · Beitrag von **Romel** » 24. Aug 2020 11:20

Ja hab ich.
Muss ich noch in openhabian was ändern?

Es scheint aber ohne Probleme zu laufen.
Nach dem reboot läuft alles.

udo1toni · Beitrag von **udo1toni** » 24. Aug 2020 14:12

Nein, dann passt das alles. Vermutlich hättest Du noch nicht mal die Bridge ändern müssen, da Port und IP ja identisch sind...

Gesendet von meinem SM-G973F mit Tapatalk

Romel · Beitrag von **Romel** » 24. Aug 2020 15:19

Wie immer ein super Service von dir !
Danke

MQTT hängt sich auf

MQTT hängt sich auf

Re: MQTT hängt sich auf

Re: MQTT hängt sich auf

Re: MQTT hängt sich auf

Re: MQTT hängt sich auf

Re: MQTT hängt sich auf

Re: MQTT hängt sich auf

Re: MQTT hängt sich auf

Re: MQTT hängt sich auf