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

Class MqttServer

java.lang.Object

br.com.anteros.mqtt.core.server.MqttServer

public final class MqttServer
extends Object

mqtt 服务端

Author:

L.cm

Method Summary

Modifier and Type	Method	Description
void	close(String clientId)	服务端主动断开连接
static MqttServerCreator	create()
org.tio.core.ChannelContext	getChannelContext(String clientId)	获取 ChannelContext
org.tio.server.ServerTioConfig	getServerConfig()	获取 ServerTioConfig
MqttServerCreator	getServerCreator()	获取 mqtt 配置
org.tio.server.TioServer	getTioServer()	获取 TioServer
MqttWebServer	getWebServer()	获取 http、websocket 服务
boolean	publish(String clientId, String topic, ByteBuffer payload)	发布消息
boolean	publish(String clientId, String topic, ByteBuffer payload, boolean retain)	发布消息
boolean	publish(String clientId, String topic, ByteBuffer payload, br.com.anteros.mqtt.codec.MqttQoS qos)	发布消息
boolean	publish(String clientId, String topic, ByteBuffer payload, br.com.anteros.mqtt.codec.MqttQoS qos, boolean retain)	发布消息
boolean	publish(org.tio.core.ChannelContext context, String clientId, String topic, ByteBuffer payload, br.com.anteros.mqtt.codec.MqttQoS qos, boolean retain)	发布消息
boolean	publishAll(String topic, ByteBuffer payload)	发布消息给所以的在线设备
boolean	publishAll(String topic, ByteBuffer payload, boolean retain)	发布消息给所以的在线设备
boolean	publishAll(String topic, ByteBuffer payload, br.com.anteros.mqtt.codec.MqttQoS qos)	发布消息
boolean	publishAll(String topic, ByteBuffer payload, br.com.anteros.mqtt.codec.MqttQoS qos, boolean retain)	发布消息给所以的在线设备
boolean	start()	启动服务
boolean	stop()	停止服务

Methods inherited from class java.lang.Object

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

Method Detail

create

public static MqttServerCreator create()

getTioServer

public org.tio.server.TioServer getTioServer()

获取 TioServer

Returns:

TioServer

getWebServer

public MqttWebServer getWebServer()

获取 http、websocket 服务

Returns:

MqttWebServer

getServerConfig

public org.tio.server.ServerTioConfig getServerConfig()

获取 ServerTioConfig

Returns:

the serverTioConfig

getServerCreator

public MqttServerCreator getServerCreator()

获取 mqtt 配置

Returns:

MqttServerCreator

publish

public boolean publish(String clientId,
                       String topic,
                       ByteBuffer payload)

发布消息

Parameters:

clientId - clientId

topic - topic

payload - 消息体

Returns:

是否发送成功

publish

public boolean publish(String clientId,
                       String topic,
                       ByteBuffer payload,
                       br.com.anteros.mqtt.codec.MqttQoS qos)

发布消息

Parameters:

clientId - clientId

topic - topic

payload - 消息体

qos - MqttQoS

Returns:

是否发送成功

publish

public boolean publish(String clientId,
                       String topic,
                       ByteBuffer payload,
                       boolean retain)

发布消息

Parameters:

clientId - clientId

topic - topic

payload - 消息体

retain - 是否在服务器上保留消息

Returns:

是否发送成功

publish

public boolean publish(String clientId,
                       String topic,
                       ByteBuffer payload,
                       br.com.anteros.mqtt.codec.MqttQoS qos,
                       boolean retain)

发布消息

Parameters:

clientId - clientId

topic - topic

payload - 消息体

qos - MqttQoS

retain - 是否在服务器上保留消息

Returns:

是否发送成功

publish

public boolean publish(org.tio.core.ChannelContext context,
                       String clientId,
                       String topic,
                       ByteBuffer payload,
                       br.com.anteros.mqtt.codec.MqttQoS qos,
                       boolean retain)

发布消息

Parameters:

context - ChannelContext

clientId - clientId

topic - topic

payload - 消息体

qos - MqttQoS

retain - 是否在服务器上保留消息

Returns:

是否发送成功

publishAll

public boolean publishAll(String topic,
                          ByteBuffer payload)

发布消息给所以的在线设备

Parameters:

topic - topic

payload - 消息体

Returns:

是否发送成功

publishAll

public boolean publishAll(String topic,
                          ByteBuffer payload,
                          br.com.anteros.mqtt.codec.MqttQoS qos)

发布消息

Parameters:

topic - topic

payload - 消息体

qos - MqttQoS

Returns:

是否发送成功

publishAll

public boolean publishAll(String topic,
                          ByteBuffer payload,
                          boolean retain)

发布消息给所以的在线设备

Parameters:

topic - topic

payload - 消息体

retain - 是否在服务器上保留消息

Returns:

是否发送成功

publishAll

public boolean publishAll(String topic,
                          ByteBuffer payload,
                          br.com.anteros.mqtt.codec.MqttQoS qos,
                          boolean retain)

发布消息给所以的在线设备

Parameters:

topic - topic

payload - 消息体

qos - MqttQoS

retain - 是否在服务器上保留消息

Returns:

是否发送成功

getChannelContext

public org.tio.core.ChannelContext getChannelContext(String clientId)

获取 ChannelContext

Parameters:

clientId - clientId

Returns:

ChannelContext

close

public void close(String clientId)

服务端主动断开连接

Parameters:

clientId - clientId

start

public boolean start()

启动服务

Returns:

是否启动

stop

public boolean stop()

停止服务

Returns:

是否停止