Package br.com.anteros.mqtt.core.server.http.core

Class MqttWebServer

java.lang.Object

br.com.anteros.mqtt.core.server.http.core.MqttWebServer

public class MqttWebServer
extends Object

mqtt web Server，集成 http 和 websocket

Author:

tanyaowu, L.cm

Constructor Summary

Constructors

Constructor	Description
MqttWebServer(MqttServerCreator serverCreator, org.tio.server.intf.ServerAioListener serverAioListener, org.tio.http.common.handler.HttpRequestHandler requestHandler, org.tio.websocket.server.handler.IWsMsgHandler wsMsgHandler, org.tio.utils.thread.pool.SynThreadPoolExecutor tioExecutor, ThreadPoolExecutor groupExecutor)
MqttWebServer(MqttServerCreator serverCreator, org.tio.server.intf.ServerAioListener serverAioListener, org.tio.websocket.server.handler.IWsMsgHandler wsMsgHandler)

Method Summary

Modifier and Type	Method	Description
static MqttWebServer	config(MqttServerCreator serverCreator, org.tio.server.ServerTioConfig mqttServerConfig)	配置 web 服务
org.tio.http.common.HttpConfig	getHttpConfig()
org.tio.http.common.handler.HttpRequestHandler	getHttpRequestHandler()
MqttWebServerAioHandler	getMqttWebServerAioHandler()
org.tio.server.ServerTioConfig	getServerTioConfig()
org.tio.server.TioServer	getTioServer()
void	start()
boolean	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MqttWebServer

public MqttWebServer(MqttServerCreator serverCreator,
                     org.tio.server.intf.ServerAioListener serverAioListener,
                     org.tio.websocket.server.handler.IWsMsgHandler wsMsgHandler)

MqttWebServer

public MqttWebServer(MqttServerCreator serverCreator,
                     org.tio.server.intf.ServerAioListener serverAioListener,
                     org.tio.http.common.handler.HttpRequestHandler requestHandler,
                     org.tio.websocket.server.handler.IWsMsgHandler wsMsgHandler,
                     org.tio.utils.thread.pool.SynThreadPoolExecutor tioExecutor,
                     ThreadPoolExecutor groupExecutor)

Method Detail

getHttpConfig

public org.tio.http.common.HttpConfig getHttpConfig()

getHttpRequestHandler

public org.tio.http.common.handler.HttpRequestHandler getHttpRequestHandler()

getMqttWebServerAioHandler

public MqttWebServerAioHandler getMqttWebServerAioHandler()

getServerTioConfig

public org.tio.server.ServerTioConfig getServerTioConfig()

getTioServer

public org.tio.server.TioServer getTioServer()

start

public void start()
           throws IOException

Throws:

IOException

stop

public boolean stop()

config

public static MqttWebServer config(MqttServerCreator serverCreator,
                                   org.tio.server.ServerTioConfig mqttServerConfig)

配置 web 服务

Parameters:

serverCreator - MqttServerCreator

mqttServerConfig - ServerTioConfig

Returns:

MqttWebServer