app.err-planeInspection.log 83 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873
  1. 2023-02-26 15:52:10.394 [MQTT Call: plane-inspection-9062] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  2. com.alibaba.fastjson.JSONException: can not cast to JSONObject.
  3. at com.alibaba.fastjson.JSON.parseObject(JSON.java:244)
  4. at com.alibaba.fastjson.JSONObject.getJSONObject(JSONObject.java:127)
  5. at com.keystar.plane.inspection.mqtt.RecognizeMqttHandler.handle(RecognizeMqttHandler.java:46)
  6. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  7. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  8. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  9. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  10. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  11. at java.lang.Thread.run(Thread.java:748)
  12. Caused by: java.lang.ClassCastException: java.lang.Integer cannot be cast to com.alibaba.fastjson.JSONObject
  13. at com.alibaba.fastjson.JSON.parseObject(JSON.java:242)
  14. ... 8 common frames omitted
  15. 2023-02-26 15:52:53.144 [MQTT Ping: plane-inspection-9062] ERROR o.eclipse.paho.client.mqttv3.internal.ClientState - plane-inspection-9062: Timed out as no write activity, keepAlive=5,000,000,000 lastOutboundActivity=714,283,495,491,000 lastInboundActivity=714,285,476,608,000 time=714,298,028,497,900 lastPing=714,283,495,497,700
  16. 2023-02-26 15:53:19.727 [MQTT Call: plane-inspection-9062] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  17. com.alibaba.fastjson.JSONException: can not cast to JSONObject.
  18. at com.alibaba.fastjson.JSON.parseObject(JSON.java:244)
  19. at com.alibaba.fastjson.JSONObject.getJSONObject(JSONObject.java:127)
  20. at com.keystar.plane.inspection.mqtt.RecognizeMqttHandler.handle(RecognizeMqttHandler.java:46)
  21. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  22. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  23. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  24. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  25. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  26. at java.lang.Thread.run(Thread.java:748)
  27. Caused by: java.lang.ClassCastException: java.lang.Integer cannot be cast to com.alibaba.fastjson.JSONObject
  28. at com.alibaba.fastjson.JSON.parseObject(JSON.java:242)
  29. ... 8 common frames omitted
  30. 2023-02-26 16:01:06.868 [MQTT Ping: plane-inspection-9062] ERROR o.eclipse.paho.client.mqttv3.internal.ClientState - plane-inspection-9062: Timed out as no write activity, keepAlive=5,000,000,000 lastOutboundActivity=714,391,264,875,800 lastInboundActivity=714,792,957,058,800 time=714,792,957,056,400 lastPing=714,391,264,879,700
  31. 2023-02-26 16:01:08.277 [MQTT Call: plane-inspection-9062] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  32. com.alibaba.fastjson.JSONException: can not cast to JSONObject.
  33. at com.alibaba.fastjson.JSON.parseObject(JSON.java:244)
  34. at com.alibaba.fastjson.JSONObject.getJSONObject(JSONObject.java:127)
  35. at com.keystar.plane.inspection.mqtt.RecognizeMqttHandler.handle(RecognizeMqttHandler.java:46)
  36. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  37. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  38. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  39. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  40. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  41. at java.lang.Thread.run(Thread.java:748)
  42. Caused by: java.lang.ClassCastException: java.lang.Integer cannot be cast to com.alibaba.fastjson.JSONObject
  43. at com.alibaba.fastjson.JSON.parseObject(JSON.java:242)
  44. ... 8 common frames omitted
  45. 2023-02-26 16:01:52.548 [MQTT Call: plane-inspection-9062] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  46. org.springframework.beans.factory.BeanCreationNotAllowedException: Error creating bean with name 'planeMqttHandler': Singleton bean creation not allowed while singletons of this factory are in destruction (Do not request a bean from a BeanFactory in a destroy method implementation!)
  47. at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:208)
  48. at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
  49. at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:224)
  50. at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveNamedBean(DefaultListableBeanFactory.java:1119)
  51. at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveBean(DefaultListableBeanFactory.java:411)
  52. at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:344)
  53. at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:337)
  54. at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1123)
  55. at com.keystar.mqtt.handler.HandlerContext.getInstance(HandlerContext.java:28)
  56. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:38)
  57. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  58. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  59. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  60. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  61. at java.lang.Thread.run(Thread.java:748)
  62. 2023-02-26 16:01:52.560 [MQTT Call: plane-inspection-9062] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  63. org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
  64. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
  65. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
  66. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
  67. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
  68. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
  69. at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
  70. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
  71. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
  72. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
  73. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
  74. at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
  75. at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
  76. at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
  77. at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
  78. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  79. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  80. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  81. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  82. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  83. at java.lang.Thread.run(Thread.java:748)
  84. Caused by: io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
  85. at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
  86. at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
  87. at io.lettuce.core.AbstractRedisClient.getConnection(AbstractRedisClient.java:235)
  88. at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
  89. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
  90. at java.util.Optional.orElseGet(Optional.java:267)
  91. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
  92. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
  93. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
  94. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
  95. at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
  96. at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
  97. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
  98. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
  99. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
  100. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
  101. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
  102. ... 19 common frames omitted
  103. Caused by: java.lang.IllegalStateException: executor not accepting a task
  104. at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:60)
  105. at io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:200)
  106. at io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:49)
  107. at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:188)
  108. at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:174)
  109. at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:502)
  110. at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:476)
  111. at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:415)
  112. at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:540)
  113. at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:529)
  114. at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:101)
  115. at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
  116. at io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1009)
  117. at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:517)
  118. at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:428)
  119. at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:487)
  120. at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
  121. at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
  122. at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
  123. at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
  124. at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
  125. at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  126. at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  127. ... 1 common frames omitted
  128. 2023-02-26 16:01:53.048 [MQTT Call: plane-inspection-9062] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  129. org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
  130. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
  131. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
  132. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
  133. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
  134. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
  135. at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
  136. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
  137. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
  138. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
  139. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
  140. at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
  141. at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
  142. at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
  143. at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
  144. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  145. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  146. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  147. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  148. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  149. at java.lang.Thread.run(Thread.java:748)
  150. Caused by: io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
  151. at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
  152. at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
  153. at io.lettuce.core.AbstractRedisClient.getConnection(AbstractRedisClient.java:235)
  154. at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
  155. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
  156. at java.util.Optional.orElseGet(Optional.java:267)
  157. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
  158. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
  159. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
  160. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
  161. at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
  162. at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
  163. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
  164. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
  165. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
  166. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
  167. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
  168. ... 19 common frames omitted
  169. Caused by: java.lang.IllegalStateException: executor not accepting a task
  170. at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:60)
  171. at io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:200)
  172. at io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:49)
  173. at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:188)
  174. at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:174)
  175. at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:502)
  176. at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:476)
  177. at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:415)
  178. at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:540)
  179. at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:529)
  180. at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:101)
  181. at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
  182. at io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1009)
  183. at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:517)
  184. at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:428)
  185. at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:487)
  186. at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
  187. at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
  188. at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
  189. at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
  190. at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
  191. at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  192. at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  193. ... 1 common frames omitted
  194. 2023-02-26 16:01:53.563 [MQTT Call: plane-inspection-9062] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  195. org.springframework.beans.factory.BeanCreationNotAllowedException: Error creating bean with name 'planeMqttHandler': Singleton bean creation not allowed while singletons of this factory are in destruction (Do not request a bean from a BeanFactory in a destroy method implementation!)
  196. at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:208)
  197. at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
  198. at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:224)
  199. at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveNamedBean(DefaultListableBeanFactory.java:1119)
  200. at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveBean(DefaultListableBeanFactory.java:411)
  201. at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:344)
  202. at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:337)
  203. at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1123)
  204. at com.keystar.mqtt.handler.HandlerContext.getInstance(HandlerContext.java:28)
  205. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:38)
  206. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  207. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  208. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  209. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  210. at java.lang.Thread.run(Thread.java:748)
  211. 2023-02-26 16:01:53.578 [MQTT Call: plane-inspection-9062] ERROR i.n.u.concurrent.DefaultPromise.rejectedExecution - Failed to submit a listener notification task. Event loop shut down?
  212. java.util.concurrent.RejectedExecutionException: event executor terminated
  213. at io.netty.util.concurrent.SingleThreadEventExecutor.reject(SingleThreadEventExecutor.java:846)
  214. at io.netty.util.concurrent.SingleThreadEventExecutor.offerTask(SingleThreadEventExecutor.java:329)
  215. at io.netty.util.concurrent.SingleThreadEventExecutor.addTask(SingleThreadEventExecutor.java:322)
  216. at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:757)
  217. at io.netty.util.concurrent.DefaultPromise.safeExecute(DefaultPromise.java:766)
  218. at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:423)
  219. at io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:152)
  220. at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:95)
  221. at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:30)
  222. at io.lettuce.core.AbstractRedisClient.initializeChannelAsync0(AbstractRedisClient.java:324)
  223. at io.lettuce.core.AbstractRedisClient.lambda$initializeChannelAsync$0(AbstractRedisClient.java:295)
  224. at reactor.core.publisher.LambdaMonoSubscriber.onNext(LambdaMonoSubscriber.java:137)
  225. at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
  226. at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
  227. at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
  228. at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1515)
  229. at reactor.core.publisher.MonoCallable.subscribe(MonoCallable.java:61)
  230. at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
  231. at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
  232. at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
  233. at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
  234. at reactor.core.publisher.Mono.subscribe(Mono.java:3848)
  235. at reactor.core.publisher.Mono.subscribeWith(Mono.java:3954)
  236. at reactor.core.publisher.Mono.subscribe(Mono.java:3842)
  237. at reactor.core.publisher.Mono.subscribe(Mono.java:3809)
  238. at reactor.core.publisher.Mono.subscribe(Mono.java:3781)
  239. at io.lettuce.core.AbstractRedisClient.initializeChannelAsync(AbstractRedisClient.java:290)
  240. at io.lettuce.core.RedisClient.connectStatefulAsync(RedisClient.java:314)
  241. at io.lettuce.core.RedisClient.connectStandaloneAsync(RedisClient.java:271)
  242. at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
  243. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
  244. at java.util.Optional.orElseGet(Optional.java:267)
  245. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
  246. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
  247. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
  248. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
  249. at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
  250. at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
  251. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
  252. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
  253. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
  254. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
  255. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
  256. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
  257. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
  258. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
  259. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
  260. at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
  261. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
  262. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
  263. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
  264. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
  265. at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
  266. at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
  267. at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
  268. at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
  269. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  270. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  271. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  272. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  273. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  274. at java.lang.Thread.run(Thread.java:748)
  275. 2023-02-26 16:03:03.807 [MQTT Ping: plane-inspection-8395] ERROR o.eclipse.paho.client.mqttv3.internal.ClientState - plane-inspection-8395: Timed out as no activity, keepAlive=5,000,000,000 lastOutboundActivity=714,879,050,235,000 lastInboundActivity=714,879,050,811,200 time=714,887,167,904,100 lastPing=714,879,050,240,900
  276. 2023-02-26 16:03:03.809 [MQTT Call: plane-inspection-8395] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  277. com.alibaba.fastjson.JSONException: can not cast to JSONObject.
  278. at com.alibaba.fastjson.JSON.parseObject(JSON.java:244)
  279. at com.alibaba.fastjson.JSONObject.getJSONObject(JSONObject.java:127)
  280. at com.keystar.plane.inspection.mqtt.RecognizeMqttHandler.handle(RecognizeMqttHandler.java:46)
  281. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  282. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  283. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  284. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  285. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  286. at java.lang.Thread.run(Thread.java:748)
  287. Caused by: java.lang.ClassCastException: java.lang.Integer cannot be cast to com.alibaba.fastjson.JSONObject
  288. at com.alibaba.fastjson.JSON.parseObject(JSON.java:242)
  289. ... 8 common frames omitted
  290. 2023-02-26 16:03:53.359 [MQTT Call: plane-inspection-8395] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  291. org.springframework.beans.factory.BeanCreationNotAllowedException: Error creating bean with name 'planeMqttHandler': Singleton bean creation not allowed while singletons of this factory are in destruction (Do not request a bean from a BeanFactory in a destroy method implementation!)
  292. at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:208)
  293. at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
  294. at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:224)
  295. at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveNamedBean(DefaultListableBeanFactory.java:1119)
  296. at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveBean(DefaultListableBeanFactory.java:411)
  297. at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:344)
  298. at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:337)
  299. at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1123)
  300. at com.keystar.mqtt.handler.HandlerContext.getInstance(HandlerContext.java:28)
  301. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:38)
  302. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  303. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  304. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  305. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  306. at java.lang.Thread.run(Thread.java:748)
  307. 2023-02-26 16:03:53.469 [MQTT Call: plane-inspection-8395] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  308. org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
  309. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
  310. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
  311. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
  312. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
  313. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
  314. at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
  315. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
  316. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
  317. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
  318. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
  319. at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
  320. at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
  321. at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
  322. at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
  323. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  324. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  325. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  326. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  327. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  328. at java.lang.Thread.run(Thread.java:748)
  329. Caused by: io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
  330. at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
  331. at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
  332. at io.lettuce.core.AbstractRedisClient.getConnection(AbstractRedisClient.java:235)
  333. at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
  334. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
  335. at java.util.Optional.orElseGet(Optional.java:267)
  336. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
  337. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
  338. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
  339. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
  340. at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
  341. at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
  342. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
  343. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
  344. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
  345. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
  346. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
  347. ... 19 common frames omitted
  348. Caused by: java.lang.IllegalStateException: executor not accepting a task
  349. at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:60)
  350. at io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:200)
  351. at io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:49)
  352. at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:188)
  353. at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:174)
  354. at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:502)
  355. at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:476)
  356. at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:415)
  357. at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:540)
  358. at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:529)
  359. at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:101)
  360. at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
  361. at io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1009)
  362. at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:517)
  363. at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:428)
  364. at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:487)
  365. at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
  366. at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
  367. at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
  368. at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
  369. at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
  370. at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  371. at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  372. ... 1 common frames omitted
  373. 2023-02-26 16:03:53.863 [MQTT Call: plane-inspection-8395] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  374. org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
  375. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
  376. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
  377. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
  378. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
  379. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
  380. at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
  381. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
  382. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
  383. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
  384. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
  385. at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
  386. at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
  387. at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
  388. at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
  389. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  390. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  391. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  392. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  393. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  394. at java.lang.Thread.run(Thread.java:748)
  395. Caused by: io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
  396. at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
  397. at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
  398. at io.lettuce.core.AbstractRedisClient.getConnection(AbstractRedisClient.java:235)
  399. at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
  400. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
  401. at java.util.Optional.orElseGet(Optional.java:267)
  402. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
  403. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
  404. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
  405. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
  406. at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
  407. at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
  408. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
  409. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
  410. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
  411. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
  412. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
  413. ... 19 common frames omitted
  414. Caused by: java.lang.IllegalStateException: executor not accepting a task
  415. at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:60)
  416. at io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:200)
  417. at io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:49)
  418. at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:188)
  419. at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:174)
  420. at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:502)
  421. at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:476)
  422. at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:415)
  423. at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:540)
  424. at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:529)
  425. at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:101)
  426. at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
  427. at io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1009)
  428. at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:517)
  429. at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:428)
  430. at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:487)
  431. at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
  432. at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
  433. at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
  434. at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
  435. at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
  436. at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  437. at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  438. ... 1 common frames omitted
  439. 2023-02-26 16:03:54.359 [MQTT Call: plane-inspection-8395] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  440. org.springframework.beans.factory.BeanCreationNotAllowedException: Error creating bean with name 'planeMqttHandler': Singleton bean creation not allowed while singletons of this factory are in destruction (Do not request a bean from a BeanFactory in a destroy method implementation!)
  441. at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:208)
  442. at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
  443. at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:224)
  444. at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveNamedBean(DefaultListableBeanFactory.java:1119)
  445. at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveBean(DefaultListableBeanFactory.java:411)
  446. at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:344)
  447. at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:337)
  448. at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1123)
  449. at com.keystar.mqtt.handler.HandlerContext.getInstance(HandlerContext.java:28)
  450. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:38)
  451. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  452. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  453. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  454. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  455. at java.lang.Thread.run(Thread.java:748)
  456. 2023-02-26 16:03:54.362 [MQTT Call: plane-inspection-8395] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  457. org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
  458. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
  459. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
  460. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
  461. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
  462. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
  463. at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
  464. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
  465. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
  466. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
  467. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
  468. at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
  469. at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
  470. at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
  471. at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
  472. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  473. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  474. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  475. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  476. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  477. at java.lang.Thread.run(Thread.java:748)
  478. Caused by: io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
  479. at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
  480. at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
  481. at io.lettuce.core.AbstractRedisClient.getConnection(AbstractRedisClient.java:235)
  482. at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
  483. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
  484. at java.util.Optional.orElseGet(Optional.java:267)
  485. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
  486. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
  487. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
  488. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
  489. at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
  490. at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
  491. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
  492. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
  493. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
  494. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
  495. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
  496. ... 19 common frames omitted
  497. Caused by: java.lang.IllegalStateException: executor not accepting a task
  498. at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:60)
  499. at io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:200)
  500. at io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:49)
  501. at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:188)
  502. at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:174)
  503. at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:502)
  504. at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:476)
  505. at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:415)
  506. at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:540)
  507. at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:529)
  508. at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:101)
  509. at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
  510. at io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1009)
  511. at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:517)
  512. at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:428)
  513. at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:487)
  514. at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
  515. at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
  516. at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
  517. at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
  518. at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
  519. at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  520. at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  521. ... 1 common frames omitted
  522. 2023-02-26 16:03:54.868 [MQTT Call: plane-inspection-8395] ERROR i.n.u.concurrent.DefaultPromise.rejectedExecution - Failed to submit a listener notification task. Event loop shut down?
  523. java.util.concurrent.RejectedExecutionException: event executor terminated
  524. at io.netty.util.concurrent.SingleThreadEventExecutor.reject(SingleThreadEventExecutor.java:846)
  525. at io.netty.util.concurrent.SingleThreadEventExecutor.offerTask(SingleThreadEventExecutor.java:329)
  526. at io.netty.util.concurrent.SingleThreadEventExecutor.addTask(SingleThreadEventExecutor.java:322)
  527. at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:757)
  528. at io.netty.util.concurrent.DefaultPromise.safeExecute(DefaultPromise.java:766)
  529. at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:423)
  530. at io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:152)
  531. at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:95)
  532. at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:30)
  533. at io.lettuce.core.AbstractRedisClient.initializeChannelAsync0(AbstractRedisClient.java:324)
  534. at io.lettuce.core.AbstractRedisClient.lambda$initializeChannelAsync$0(AbstractRedisClient.java:295)
  535. at reactor.core.publisher.LambdaMonoSubscriber.onNext(LambdaMonoSubscriber.java:137)
  536. at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
  537. at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
  538. at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
  539. at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1515)
  540. at reactor.core.publisher.MonoCallable.subscribe(MonoCallable.java:61)
  541. at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
  542. at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
  543. at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
  544. at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
  545. at reactor.core.publisher.Mono.subscribe(Mono.java:3848)
  546. at reactor.core.publisher.Mono.subscribeWith(Mono.java:3954)
  547. at reactor.core.publisher.Mono.subscribe(Mono.java:3842)
  548. at reactor.core.publisher.Mono.subscribe(Mono.java:3809)
  549. at reactor.core.publisher.Mono.subscribe(Mono.java:3781)
  550. at io.lettuce.core.AbstractRedisClient.initializeChannelAsync(AbstractRedisClient.java:290)
  551. at io.lettuce.core.RedisClient.connectStatefulAsync(RedisClient.java:314)
  552. at io.lettuce.core.RedisClient.connectStandaloneAsync(RedisClient.java:271)
  553. at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
  554. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
  555. at java.util.Optional.orElseGet(Optional.java:267)
  556. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
  557. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
  558. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
  559. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
  560. at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
  561. at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
  562. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
  563. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
  564. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
  565. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
  566. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
  567. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
  568. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
  569. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
  570. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
  571. at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
  572. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
  573. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
  574. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
  575. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
  576. at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
  577. at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
  578. at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
  579. at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
  580. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  581. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  582. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  583. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  584. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  585. at java.lang.Thread.run(Thread.java:748)
  586. 2023-02-26 16:04:32.548 [MQTT Ping: plane-inspection-301] ERROR o.eclipse.paho.client.mqttv3.internal.ClientState - plane-inspection-301: Timed out as no write activity, keepAlive=5,000,000,000 lastOutboundActivity=714,986,109,119,700 lastInboundActivity=714,998,634,340,100 time=714,998,634,404,400 lastPing=714,986,109,122,700
  587. 2023-02-26 16:10:01.061 [MQTT Call: plane-inspection-301] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  588. java.lang.NullPointerException: null
  589. at com.keystar.plane.inspection.mqtt.RecognizeMqttHandler.handle(RecognizeMqttHandler.java:53)
  590. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  591. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  592. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  593. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  594. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  595. at java.lang.Thread.run(Thread.java:748)
  596. 2023-02-26 16:10:01.605 [MQTT Call: plane-inspection-301] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  597. org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is java.lang.IllegalStateException: Pool not open
  598. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
  599. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
  600. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
  601. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
  602. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
  603. at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
  604. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
  605. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
  606. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
  607. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
  608. at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
  609. at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
  610. at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
  611. at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
  612. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  613. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  614. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  615. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  616. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  617. at java.lang.Thread.run(Thread.java:748)
  618. Caused by: java.lang.IllegalStateException: Pool not open
  619. at org.apache.commons.pool2.impl.BaseGenericObjectPool.assertOpen(BaseGenericObjectPool.java:713)
  620. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:411)
  621. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
  622. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
  623. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
  624. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
  625. ... 19 common frames omitted
  626. 2023-02-26 16:10:01.606 [MQTT Call: plane-inspection-301] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  627. org.springframework.beans.factory.BeanCreationNotAllowedException: Error creating bean with name 'planeMqttHandler': Singleton bean creation not allowed while singletons of this factory are in destruction (Do not request a bean from a BeanFactory in a destroy method implementation!)
  628. at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:208)
  629. at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
  630. at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:224)
  631. at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveNamedBean(DefaultListableBeanFactory.java:1119)
  632. at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveBean(DefaultListableBeanFactory.java:411)
  633. at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:344)
  634. at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:337)
  635. at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1123)
  636. at com.keystar.mqtt.handler.HandlerContext.getInstance(HandlerContext.java:28)
  637. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:38)
  638. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  639. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  640. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  641. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  642. at java.lang.Thread.run(Thread.java:748)
  643. 2023-02-26 16:11:23.920 [MQTT Ping: plane-inspection-6523] ERROR o.eclipse.paho.client.mqttv3.internal.ClientState - plane-inspection-6523: Timed out as no activity, keepAlive=5,000,000,000 lastOutboundActivity=715,403,664,433,100 lastInboundActivity=715,402,750,043,700 time=715,410,008,556,500 lastPing=715,403,664,472,900
  644. 2023-02-26 16:12:19.989 [MQTT Call: plane-inspection-6523] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  645. org.springframework.beans.factory.BeanCreationNotAllowedException: Error creating bean with name 'planeMqttHandler': Singleton bean creation not allowed while singletons of this factory are in destruction (Do not request a bean from a BeanFactory in a destroy method implementation!)
  646. at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:208)
  647. at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
  648. at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:224)
  649. at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveNamedBean(DefaultListableBeanFactory.java:1119)
  650. at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveBean(DefaultListableBeanFactory.java:411)
  651. at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:344)
  652. at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:337)
  653. at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1123)
  654. at com.keystar.mqtt.handler.HandlerContext.getInstance(HandlerContext.java:28)
  655. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:38)
  656. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  657. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  658. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  659. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  660. at java.lang.Thread.run(Thread.java:748)
  661. 2023-02-26 16:12:20.000 [MQTT Call: plane-inspection-6523] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  662. org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
  663. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
  664. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
  665. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
  666. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
  667. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
  668. at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
  669. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
  670. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
  671. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
  672. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
  673. at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
  674. at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
  675. at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
  676. at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
  677. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  678. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  679. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  680. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  681. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  682. at java.lang.Thread.run(Thread.java:748)
  683. Caused by: io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
  684. at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
  685. at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
  686. at io.lettuce.core.AbstractRedisClient.getConnection(AbstractRedisClient.java:235)
  687. at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
  688. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
  689. at java.util.Optional.orElseGet(Optional.java:267)
  690. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
  691. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
  692. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
  693. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
  694. at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
  695. at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
  696. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
  697. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
  698. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
  699. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
  700. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
  701. ... 19 common frames omitted
  702. Caused by: java.lang.IllegalStateException: executor not accepting a task
  703. at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:60)
  704. at io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:200)
  705. at io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:49)
  706. at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:188)
  707. at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:174)
  708. at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:502)
  709. at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:476)
  710. at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:415)
  711. at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:540)
  712. at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:529)
  713. at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:101)
  714. at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
  715. at io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1009)
  716. at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:517)
  717. at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:428)
  718. at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:487)
  719. at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
  720. at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
  721. at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
  722. at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
  723. at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
  724. at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  725. at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  726. ... 1 common frames omitted
  727. 2023-02-26 16:12:20.479 [MQTT Call: plane-inspection-6523] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  728. org.springframework.data.redis.connection.PoolException: Could not get a resource from the pool; nested exception is io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
  729. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:86)
  730. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
  731. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
  732. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
  733. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
  734. at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
  735. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
  736. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
  737. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
  738. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
  739. at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
  740. at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
  741. at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
  742. at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
  743. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  744. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  745. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  746. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  747. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  748. at java.lang.Thread.run(Thread.java:748)
  749. Caused by: io.lettuce.core.RedisConnectionException: Unable to connect to 10.138.6.221:6379
  750. at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:78)
  751. at io.lettuce.core.RedisConnectionException.create(RedisConnectionException.java:56)
  752. at io.lettuce.core.AbstractRedisClient.getConnection(AbstractRedisClient.java:235)
  753. at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
  754. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
  755. at java.util.Optional.orElseGet(Optional.java:267)
  756. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
  757. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
  758. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
  759. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
  760. at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
  761. at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
  762. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
  763. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
  764. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
  765. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
  766. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
  767. ... 19 common frames omitted
  768. Caused by: java.lang.IllegalStateException: executor not accepting a task
  769. at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:60)
  770. at io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:200)
  771. at io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:49)
  772. at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:188)
  773. at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:174)
  774. at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:502)
  775. at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:476)
  776. at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:415)
  777. at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:540)
  778. at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:529)
  779. at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:101)
  780. at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
  781. at io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1009)
  782. at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:517)
  783. at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:428)
  784. at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:487)
  785. at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
  786. at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
  787. at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:405)
  788. at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
  789. at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906)
  790. at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  791. at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  792. ... 1 common frames omitted
  793. 2023-02-26 16:12:20.978 [MQTT Call: plane-inspection-6523] ERROR com.keystar.mqtt.processor.MessageHandleService - 处理mqtt消息出错:{}
  794. org.springframework.beans.factory.BeanCreationNotAllowedException: Error creating bean with name 'planeMqttHandler': Singleton bean creation not allowed while singletons of this factory are in destruction (Do not request a bean from a BeanFactory in a destroy method implementation!)
  795. at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:208)
  796. at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
  797. at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:224)
  798. at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveNamedBean(DefaultListableBeanFactory.java:1119)
  799. at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveBean(DefaultListableBeanFactory.java:411)
  800. at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:344)
  801. at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBean(DefaultListableBeanFactory.java:337)
  802. at org.springframework.context.support.AbstractApplicationContext.getBean(AbstractApplicationContext.java:1123)
  803. at com.keystar.mqtt.handler.HandlerContext.getInstance(HandlerContext.java:28)
  804. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:38)
  805. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  806. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  807. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  808. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  809. at java.lang.Thread.run(Thread.java:748)
  810. 2023-02-26 16:12:20.989 [MQTT Call: plane-inspection-6523] ERROR i.n.u.concurrent.DefaultPromise.rejectedExecution - Failed to submit a listener notification task. Event loop shut down?
  811. java.util.concurrent.RejectedExecutionException: event executor terminated
  812. at io.netty.util.concurrent.SingleThreadEventExecutor.reject(SingleThreadEventExecutor.java:846)
  813. at io.netty.util.concurrent.SingleThreadEventExecutor.offerTask(SingleThreadEventExecutor.java:329)
  814. at io.netty.util.concurrent.SingleThreadEventExecutor.addTask(SingleThreadEventExecutor.java:322)
  815. at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:757)
  816. at io.netty.util.concurrent.DefaultPromise.safeExecute(DefaultPromise.java:766)
  817. at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:423)
  818. at io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:152)
  819. at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:95)
  820. at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:30)
  821. at io.lettuce.core.AbstractRedisClient.initializeChannelAsync0(AbstractRedisClient.java:324)
  822. at io.lettuce.core.AbstractRedisClient.lambda$initializeChannelAsync$0(AbstractRedisClient.java:295)
  823. at reactor.core.publisher.LambdaMonoSubscriber.onNext(LambdaMonoSubscriber.java:137)
  824. at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
  825. at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
  826. at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
  827. at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1515)
  828. at reactor.core.publisher.MonoCallable.subscribe(MonoCallable.java:61)
  829. at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
  830. at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
  831. at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
  832. at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
  833. at reactor.core.publisher.Mono.subscribe(Mono.java:3848)
  834. at reactor.core.publisher.Mono.subscribeWith(Mono.java:3954)
  835. at reactor.core.publisher.Mono.subscribe(Mono.java:3842)
  836. at reactor.core.publisher.Mono.subscribe(Mono.java:3809)
  837. at reactor.core.publisher.Mono.subscribe(Mono.java:3781)
  838. at io.lettuce.core.AbstractRedisClient.initializeChannelAsync(AbstractRedisClient.java:290)
  839. at io.lettuce.core.RedisClient.connectStatefulAsync(RedisClient.java:314)
  840. at io.lettuce.core.RedisClient.connectStandaloneAsync(RedisClient.java:271)
  841. at io.lettuce.core.RedisClient.connect(RedisClient.java:204)
  842. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.lambda$getConnection$1(StandaloneConnectionProvider.java:113)
  843. at java.util.Optional.orElseGet(Optional.java:267)
  844. at org.springframework.data.redis.connection.lettuce.StandaloneConnectionProvider.getConnection(StandaloneConnectionProvider.java:113)
  845. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.lambda$null$0(LettucePoolingConnectionProvider.java:74)
  846. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:209)
  847. at io.lettuce.core.support.ConnectionPoolSupport$RedisPooledObjectFactory.create(ConnectionPoolSupport.java:199)
  848. at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:58)
  849. at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:889)
  850. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:433)
  851. at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:362)
  852. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:122)
  853. at io.lettuce.core.support.ConnectionPoolSupport$1.borrowObject(ConnectionPoolSupport.java:117)
  854. at org.springframework.data.redis.connection.lettuce.LettucePoolingConnectionProvider.getConnection(LettucePoolingConnectionProvider.java:80)
  855. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getNativeConnection(LettuceConnectionFactory.java:1104)
  856. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory$SharedConnection.getConnection(LettuceConnectionFactory.java:1085)
  857. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getSharedConnection(LettuceConnectionFactory.java:866)
  858. at org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory.getConnection(LettuceConnectionFactory.java:341)
  859. at org.springframework.data.redis.core.RedisConnectionUtils.doGetConnection(RedisConnectionUtils.java:132)
  860. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:95)
  861. at org.springframework.data.redis.core.RedisConnectionUtils.getConnection(RedisConnectionUtils.java:82)
  862. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:211)
  863. at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
  864. at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
  865. at org.springframework.data.redis.core.DefaultValueOperations.set(DefaultValueOperations.java:236)
  866. at com.keystar.plane.inspection.utils.RedisUtils.set(RedisUtils.java:54)
  867. at com.keystar.plane.inspection.mqtt.NestMqttHandler.handle(NestMqttHandler.java:41)
  868. at com.keystar.mqtt.processor.MessageHandleService.handle(MessageHandleService.java:39)
  869. at com.keystar.mqtt.util.SubScribeUtil.lambda$subScribe$0(SubScribeUtil.java:31)
  870. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.deliverMessage(CommsCallback.java:511)
  871. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:417)
  872. at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:214)
  873. at java.lang.Thread.run(Thread.java:748)