直接在RabbitMQ上用的mqtt,
连接本地没有问题，当连接远程电脑的时候就会报错， tcp://localhost:1883是没有问题的
rabbitmq 账号也用的不是guest/guest
# Mqtt配置
mqtt:
url: tcp://192.168.3.83:1883
username: admin
password: admin
topic: communication/2/#
. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
\\/ ___)| |_)| | | | | || (_| | ) ) ) )
' |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: Spring Boot :: (v2.4.1)
2021-09-30 17:00:02.010 INFO 9408 --- [ main] com.guitu.EdgeServerApplication : Starting EdgeServerApplication using Java 1.8.0_221 on DESKTOP-RAV3FU6 with PID 9408 (E:\imonitor\msmonitor-edge-server\target\classes started by Murray in E:\imonitor)
2021-09-30 17:00:02.023 INFO 9408 --- [ main] com.guitu.EdgeServerApplication : No active profile set, falling back to default profiles: default
2021-09-30 17:00:03.188 INFO 9408 --- [ main] faultConfiguringBeanFactoryPostProcessor : No bean named 'errorChannel' has been explicitly defined. Therefore, a default PublishSubscribeChannel will be created.
2021-09-30 17:00:03.198 INFO 9408 --- [ main] faultConfiguringBeanFactoryPostProcessor : No bean named 'taskScheduler' has been explicitly defined. Therefore, a default ThreadPoolTaskScheduler will be created.
2021-09-30 17:00:03.204 INFO 9408 --- [ main] faultConfiguringBeanFactoryPostProcessor : No bean named 'integrationHeaderChannelRegistry' has been explicitly defined. Therefore, a default DefaultHeaderChannelRegistry will be created.
2021-09-30 17:00:03.305 INFO 9408 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.integration.config.IntegrationManagementConfiguration' of type [org.springframework.integration.config.IntegrationManagementConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2021-09-30 17:00:03.321 INFO 9408 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'integrationChannelResolver' of type [org.springframework.integration.support.channel.BeanFactoryChannelResolver] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2021-09-30 17:00:03.323 INFO 9408 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'integrationDisposableAutoCreatedBeans' of type [org.springframework.integration.config.annotation.Disposables] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2021-09-30 17:00:03.603 INFO 9408 --- [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat initialized with port(s): 8071 (http)
2021-09-30 17:00:03.623 INFO 9408 --- [ main] o.a.coyote.http11.Http11NioProtocol : Initializing ProtocolHandler ["http-nio-8071"]
2021-09-30 17:00:03.623 INFO 9408 --- [ main] o.apache.catalina.core.StandardService : Starting service [Tomcat]
2021-09-30 17:00:03.624 INFO 9408 --- [ main] org.apache.catalina.core.StandardEngine : Starting Servlet engine: [Apache Tomcat/9.0.41]
2021-09-30 17:00:03.751 INFO 9408 --- [ main] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring embedded WebApplicationContext
2021-09-30 17:00:03.751 INFO 9408 --- [ main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 1624 ms
2021-09-30 17:00:04.896 INFO 9408 --- [ main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 'taskScheduler'
2021-09-30 17:00:05.173 INFO 9408 --- [ main] o.s.s.concurrent.ThreadPoolTaskExecutor : Initializing ExecutorService 'applicationTaskExecutor'
2021-09-30 17:00:05.709 INFO 9408 --- [ main] o.s.i.endpoint.EventDrivenConsumer : Adding {logging-channel-adapter:_org.springframework.integration.errorLogger} as a subscriber to the 'errorChannel' channel
2021-09-30 17:00:05.709 INFO 9408 --- [ main] o.s.i.channel.PublishSubscribeChannel : Channel 'msmonitor-edge-server.errorChannel' has 1 subscriber(s).
2021-09-30 17:00:05.709 INFO 9408 --- [ main] o.s.i.endpoint.EventDrivenConsumer : started bean '_org.springframework.integration.errorLogger'
2021-09-30 17:00:05.709 INFO 9408 --- [ main] o.s.i.endpoint.EventDrivenConsumer : Adding {message-handler:mqttInboundConfig.handler.serviceActivator} as a subscriber to the 'mqttInputChannel' channel
2021-09-30 17:00:05.709 INFO 9408 --- [ main] o.s.integration.channel.DirectChannel : Channel 'msmonitor-edge-server.mqttInputChannel' has 1 subscriber(s).
2021-09-30 17:00:05.709 INFO 9408 --- [ main] o.s.i.endpoint.EventDrivenConsumer : started bean 'mqttInboundConfig.handler.serviceActivator'
2021-09-30 17:00:05.709 INFO 9408 --- [ main] o.s.i.endpoint.EventDrivenConsumer : Adding {message-handler:mqttOutboundConfig.mqttOutbound.serviceActivator} as a subscriber to the 'mqttOutboundChannel' channel
2021-09-30 17:00:05.710 INFO 9408 --- [ main] o.s.integration.channel.DirectChannel : Channel 'msmonitor-edge-server.mqttOutboundChannel' has 1 subscriber(s).
2021-09-30 17:00:05.710 INFO 9408 --- [ main] o.s.i.endpoint.EventDrivenConsumer : started bean 'mqttOutboundConfig.mqttOutbound.serviceActivator'
2021-09-30 17:00:05.710 INFO 9408 --- [ main] ProxyFactoryBean$MethodInvocationGateway : started bean 'mqttGateway#sendToMqtt(String)'
2021-09-30 17:00:05.710 INFO 9408 --- [ main] ProxyFactoryBean$MethodInvocationGateway : started bean 'mqttGateway#sendToMqtt(String, String)'
2021-09-30 17:00:05.710 INFO 9408 --- [ main] ProxyFactoryBean$MethodInvocationGateway : started bean 'mqttGateway#sendToMqtt(String, int, String)'
2021-09-30 17:00:05.710 INFO 9408 --- [ main] o.s.i.gateway.GatewayProxyFactoryBean : started bean 'mqttGateway'
2021-09-30 17:00:05.807 ERROR 9408 --- [ main] .m.i.MqttPahoMessageDrivenChannelAdapter : Error connecting or subscribing to [communication/2/#]
org.eclipse.paho.client.mqttv3.MqttSecurityException: 无权连接
at org.eclipse.paho.client.mqttv3.internal.ExceptionHelper.createMqttException(ExceptionHelper.java:28)
at org.eclipse.paho.client.mqttv3.internal.ClientState.notifyReceivedAck(ClientState.java:988)
at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:145)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266)
at java.util.concurrent.FutureTask.run(FutureTask.java)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
2021-09-30 17:00:05.809 ERROR 9408 --- [ main] .m.i.MqttPahoMessageDrivenChannelAdapter : Exception while connecting and subscribing, retrying
org.eclipse.paho.client.mqttv3.MqttSecurityException: 无权连接
at org.eclipse.paho.client.mqttv3.internal.ExceptionHelper.createMqttException(ExceptionHelper.java:28)
at org.eclipse.paho.client.mqttv3.internal.ClientState.notifyReceivedAck(ClientState.java:988)
at org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:145)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266)
at java.util.concurrent.FutureTask.run(FutureTask.java)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)