提交 b51f497c 编写于 作者: 如梦技术's avatar 如梦技术 🐛

添加日志,websocket 移到到 http 包。

上级 ef09e957
...@@ -199,7 +199,9 @@ import net.dreamlu.iot.mqtt.core.server.http.api.MqttHttpApi; ...@@ -199,7 +199,9 @@ import net.dreamlu.iot.mqtt.core.server.http.api.MqttHttpApi;
import net.dreamlu.iot.mqtt.core.server.http.api.auth.BasicAuthFilter; import net.dreamlu.iot.mqtt.core.server.http.api.auth.BasicAuthFilter;
import net.dreamlu.iot.mqtt.core.server.http.handler.MqttHttpRequestHandler; import net.dreamlu.iot.mqtt.core.server.http.handler.MqttHttpRequestHandler;
import net.dreamlu.iot.mqtt.core.server.http.handler.MqttHttpRoutes; import net.dreamlu.iot.mqtt.core.server.http.handler.MqttHttpRoutes;
import net.dreamlu.iot.mqtt.core.server.websocket.MqttWsMsgHandler; import net.dreamlu.iot.mqtt.core.server.http.websocket.MqttWsMsgHandler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.tio.core.intf.AioHandler; import org.tio.core.intf.AioHandler;
import org.tio.http.common.HttpConfig; import org.tio.http.common.HttpConfig;
import org.tio.http.common.HttpUuid; import org.tio.http.common.HttpUuid;
...@@ -222,6 +224,7 @@ import java.util.concurrent.ThreadPoolExecutor; ...@@ -222,6 +224,7 @@ import java.util.concurrent.ThreadPoolExecutor;
* @author L.cm * @author L.cm
*/ */
public class MqttWebServer { public class MqttWebServer {
private static final Logger logger = LoggerFactory.getLogger(MqttWebServer.class);
private static final String TIO_SYSTEM_TIMER_PERIOD = "tio.system.timer.period"; private static final String TIO_SYSTEM_TIMER_PERIOD = "tio.system.timer.period";
private final MqttWebServerAioListener mqttWebServerAioListener; private final MqttWebServerAioListener mqttWebServerAioListener;
private final HttpRequestHandler httpRequestHandler; private final HttpRequestHandler httpRequestHandler;
...@@ -310,6 +313,7 @@ public class MqttWebServer { ...@@ -310,6 +313,7 @@ public class MqttWebServer {
// 1. 判断是否开启 // 1. 判断是否开启
boolean httpEnable = serverCreator.isHttpEnable(); boolean httpEnable = serverCreator.isHttpEnable();
boolean websocketEnable = serverCreator.isWebsocketEnable(); boolean websocketEnable = serverCreator.isWebsocketEnable();
logger.info("Mica mqtt http api enable:{} websocket enable:{}", httpEnable, websocketEnable);
if (!httpEnable && !websocketEnable) { if (!httpEnable && !websocketEnable) {
return null; return null;
} }
......
...@@ -14,7 +14,7 @@ ...@@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
*/ */
package net.dreamlu.iot.mqtt.core.server.websocket; package net.dreamlu.iot.mqtt.core.server.http.websocket;
import net.dreamlu.iot.mqtt.codec.ByteBufferUtil; import net.dreamlu.iot.mqtt.codec.ByteBufferUtil;
import net.dreamlu.iot.mqtt.codec.MqttMessage; import net.dreamlu.iot.mqtt.codec.MqttMessage;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册