net.dreamlu.iot.mqtt.core.client

类 MqttClientCreator

java.lang.Object

net.dreamlu.iot.mqtt.core.client.MqttClientCreator

public final class MqttClientCreator
extends Object

mqtt 客户端构造器

作者:

L.cm

字段概要

字段

限定符和类型	字段和说明
static int	DEFAULT_KEEP_ALIVE_SECS 默认的心跳超时

构造器概要

构造器

构造器和说明
MqttClientCreator()

方法概要

限定符和类型	方法和说明
MqttClientCreator	bufferAllocator(net.dreamlu.iot.mqtt.codec.ByteBufferAllocator allocator)
MqttClientCreator	cleanSession(boolean cleanSession)
MqttClientCreator	clientId(String clientId)
MqttClientCreator	clientSession(IMqttClientSession clientSession)
MqttClient	connect() 默认异步连接
MqttClientCreator	connectListener(IMqttClientConnectListener connectListener)
MqttClient	connectSync() 同步连接
MqttClientCreator	debug()
net.dreamlu.iot.mqtt.codec.ByteBufferAllocator	getBufferAllocator()
String	getClientId()
IMqttClientSession	getClientSession()
IMqttClientConnectListener	getConnectListener()
ThreadPoolExecutor	getGroupExecutor()
String	getIp()
int	getKeepAliveSecs()
int	getMaxBytesInMessage()
int	getMaxClientIdLength()
IMqttClientMessageIdGenerator	getMessageIdGenerator()
ThreadPoolExecutor	getMqttExecutor()
String	getName()
String	getPassword()
int	getPort()
net.dreamlu.iot.mqtt.codec.MqttProperties	getProperties()
int	getReadBufferSize()
long	getReInterval()
int	getReSubscribeBatchSize()
int	getRetryCount()
Integer	getSessionExpiryIntervalSecs()
org.tio.core.ssl.SslConfig	getSslConfig()
org.tio.utils.timer.TimerTaskService	getTaskService()
Integer	getTimeout()
org.tio.utils.thread.pool.SynThreadPoolExecutor	getTioExecutor()
String	getUsername()
net.dreamlu.iot.mqtt.codec.MqttVersion	getVersion()
MqttWillMessage	getWillMessage()
MqttClientCreator	groupExecutor(ThreadPoolExecutor groupExecutor)
MqttClientCreator	ip(String ip)
boolean	isCleanSession()
boolean	isDebug()
boolean	isReconnect()
boolean	isStatEnable()
MqttClientCreator	keepAliveSecs(int keepAliveSecs)
MqttClientCreator	maxBytesInMessage(int maxBytesInMessage)
MqttClientCreator	maxClientIdLength(int maxClientIdLength)
MqttClientCreator	messageIdGenerator(IMqttClientMessageIdGenerator messageIdGenerator)
MqttClientCreator	mqttExecutor(ThreadPoolExecutor mqttExecutor)
MqttClientCreator	name(String name)
MqttClientCreator	password(String password)
MqttClientCreator	port(int port)
MqttClientCreator	properties(net.dreamlu.iot.mqtt.codec.MqttProperties properties)
MqttClientCreator	readBufferSize(int readBufferSize)
MqttClientCreator	reconnect(boolean reconnect)
MqttClientCreator	reInterval(long reInterval)
MqttClientCreator	reSubscribeBatchSize(int reSubscribeBatchSize)
MqttClientCreator	retryCount(int retryCount)
MqttClientCreator	sessionExpiryIntervalSecs(Integer sessionExpiryIntervalSecs)
MqttClientCreator	sslConfig(org.tio.core.ssl.SslConfig sslConfig)
MqttClientCreator	statEnable()
MqttClientCreator	statEnable(boolean enable)
MqttClientCreator	taskService(org.tio.utils.timer.TimerTaskService taskService)
MqttClientCreator	timeout(int timeout)
MqttClientCreator	tioConfigCustomize(Consumer<org.tio.core.TioConfig> tioConfigCustomize)
MqttClientCreator	tioExecutor(org.tio.utils.thread.pool.SynThreadPoolExecutor tioExecutor)
MqttClientCreator	username(String username)
MqttClientCreator	useSsl()
MqttClientCreator	useSsl(InputStream trustStoreInputStream, String trustPassword)
MqttClientCreator	useSsl(InputStream keyStoreInputStream, String keyPasswd, InputStream trustStoreInputStream, String trustPassword)
MqttClientCreator	useSsl(String trustStoreFile, String trustPassword)
MqttClientCreator	useSsl(String keyStoreFile, String keyPasswd, String trustStoreFile, String trustPassword)
MqttClientCreator	version(net.dreamlu.iot.mqtt.codec.MqttVersion version)
MqttClientCreator	willMessage(Consumer<MqttWillMessage.Builder> consumer)
MqttClientCreator	willMessage(MqttWillMessage willMessage)

从类继承的方法 java.lang.Object

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

字段详细资料

DEFAULT_KEEP_ALIVE_SECS

public static final int DEFAULT_KEEP_ALIVE_SECS

默认的心跳超时

另请参阅:

常量字段值

构造器详细资料

MqttClientCreator

public MqttClientCreator()

方法详细资料

getName

public String getName()

getIp

public String getIp()

getPort

public int getPort()

getTimeout

public Integer getTimeout()

getReadBufferSize

public int getReadBufferSize()

getMaxBytesInMessage

public int getMaxBytesInMessage()

getMaxClientIdLength

public int getMaxClientIdLength()

getKeepAliveSecs

public int getKeepAliveSecs()

getSslConfig

public org.tio.core.ssl.SslConfig getSslConfig()

isReconnect

public boolean isReconnect()

getRetryCount

public int getRetryCount()

getReInterval

public long getReInterval()

getReSubscribeBatchSize

public int getReSubscribeBatchSize()

getClientId

public String getClientId()

getVersion

public net.dreamlu.iot.mqtt.codec.MqttVersion getVersion()

getUsername

public String getUsername()

getPassword

public String getPassword()

isCleanSession

public boolean isCleanSession()

getSessionExpiryIntervalSecs

public Integer getSessionExpiryIntervalSecs()

getWillMessage

public MqttWillMessage getWillMessage()

getProperties

public net.dreamlu.iot.mqtt.codec.MqttProperties getProperties()

getBufferAllocator

public net.dreamlu.iot.mqtt.codec.ByteBufferAllocator getBufferAllocator()

getConnectListener

public IMqttClientConnectListener getConnectListener()

getClientSession

public IMqttClientSession getClientSession()

getMessageIdGenerator

public IMqttClientMessageIdGenerator getMessageIdGenerator()

isStatEnable

public boolean isStatEnable()

isDebug

public boolean isDebug()

getTioExecutor

public org.tio.utils.thread.pool.SynThreadPoolExecutor getTioExecutor()

getGroupExecutor

public ThreadPoolExecutor getGroupExecutor()

getMqttExecutor

public ThreadPoolExecutor getMqttExecutor()

getTaskService

public org.tio.utils.timer.TimerTaskService getTaskService()

name

public MqttClientCreator name(String name)

ip

public MqttClientCreator ip(String ip)

port

public MqttClientCreator port(int port)

timeout

public MqttClientCreator timeout(int timeout)

readBufferSize

public MqttClientCreator readBufferSize(int readBufferSize)

maxBytesInMessage

public MqttClientCreator maxBytesInMessage(int maxBytesInMessage)

maxClientIdLength

public MqttClientCreator maxClientIdLength(int maxClientIdLength)

keepAliveSecs

public MqttClientCreator keepAliveSecs(int keepAliveSecs)

useSsl

public MqttClientCreator useSsl()

useSsl

public MqttClientCreator useSsl(String trustStoreFile,
                                String trustPassword)

useSsl

public MqttClientCreator useSsl(String keyStoreFile,
                                String keyPasswd,
                                String trustStoreFile,
                                String trustPassword)

useSsl

public MqttClientCreator useSsl(InputStream trustStoreInputStream,
                                String trustPassword)

useSsl

public MqttClientCreator useSsl(InputStream keyStoreInputStream,
                                String keyPasswd,
                                InputStream trustStoreInputStream,
                                String trustPassword)

sslConfig

public MqttClientCreator sslConfig(org.tio.core.ssl.SslConfig sslConfig)

reconnect

public MqttClientCreator reconnect(boolean reconnect)

retryCount

public MqttClientCreator retryCount(int retryCount)

reInterval

public MqttClientCreator reInterval(long reInterval)

reSubscribeBatchSize

public MqttClientCreator reSubscribeBatchSize(int reSubscribeBatchSize)

clientId

public MqttClientCreator clientId(String clientId)

version

public MqttClientCreator version(net.dreamlu.iot.mqtt.codec.MqttVersion version)

username

public MqttClientCreator username(String username)

password

public MqttClientCreator password(String password)

cleanSession

public MqttClientCreator cleanSession(boolean cleanSession)

sessionExpiryIntervalSecs

public MqttClientCreator sessionExpiryIntervalSecs(Integer sessionExpiryIntervalSecs)

willMessage

public MqttClientCreator willMessage(MqttWillMessage willMessage)

willMessage

public MqttClientCreator willMessage(Consumer<MqttWillMessage.Builder> consumer)

properties

public MqttClientCreator properties(net.dreamlu.iot.mqtt.codec.MqttProperties properties)

bufferAllocator

public MqttClientCreator bufferAllocator(net.dreamlu.iot.mqtt.codec.ByteBufferAllocator allocator)

connectListener

public MqttClientCreator connectListener(IMqttClientConnectListener connectListener)

clientSession

public MqttClientCreator clientSession(IMqttClientSession clientSession)

messageIdGenerator

public MqttClientCreator messageIdGenerator(IMqttClientMessageIdGenerator messageIdGenerator)

statEnable

public MqttClientCreator statEnable()

statEnable

public MqttClientCreator statEnable(boolean enable)

debug

public MqttClientCreator debug()

tioExecutor

public MqttClientCreator tioExecutor(org.tio.utils.thread.pool.SynThreadPoolExecutor tioExecutor)

groupExecutor

public MqttClientCreator groupExecutor(ThreadPoolExecutor groupExecutor)

mqttExecutor

public MqttClientCreator mqttExecutor(ThreadPoolExecutor mqttExecutor)

taskService

public MqttClientCreator taskService(org.tio.utils.timer.TimerTaskService taskService)

tioConfigCustomize

public MqttClientCreator tioConfigCustomize(Consumer<org.tio.core.TioConfig> tioConfigCustomize)

connect

public MqttClient connect()

默认异步连接

返回:

TioClient

connectSync

public MqttClient connectSync()

同步连接

返回:

TioClient