MqttHelper 类 |
命名空间: HslCommunication.MQTT
MqttHelper 类型公开以下成员。
名称 | 说明 | |
---|---|---|
MqttHelper | 初始化 MqttHelper 类的一个新实例 |
名称 | 说明 | |
---|---|---|
BuildConnectMqttCommand |
创建MQTT连接服务器的报文信息 Create MQTT connection server message information | |
BuildIntBytes |
从MQTT的缓存信息里,提取长度信息 Extract length information from MQTT cache information | |
BuildMqttCommand(Byte, Byte, Byte, AesCryptography) |
将一个数据打包成一个mqtt协议的内容 Pack a piece of data into a mqtt protocol | |
BuildMqttCommand(Byte, Byte, Byte, Byte, AesCryptography) |
将一个数据打包成一个mqtt协议的内容 Pack a piece of data into a mqtt protocol | |
BuildPublishMqttCommand(MqttPublishMessage, AesCryptography) |
创建Mqtt发送消息的命令 Create Mqtt command to send messages | |
BuildPublishMqttCommand(String, Byte, Boolean, AesCryptography) |
创建Mqtt发送消息的命令 Create Mqtt command to send messages | |
BuildSegCommandByString(Byte) |
将字符串打包成utf8编码,并且带有2个字节的表示长度的信息 Pack the string into utf8 encoding, and with 2 bytes of length information | |
BuildSegCommandByString(String) |
将字符串打包成utf8编码,并且带有2个字节的表示长度的信息 Pack the string into utf8 encoding, and with 2 bytes of length information | |
BuildSubscribeMqttCommand |
创建Mqtt订阅消息的命令 Command to create Mqtt subscription message | |
BuildUnSubscribeMqttCommand |
创建Mqtt取消订阅消息的命令 Create Mqtt unsubscribe message command | |
CalculateLengthToMqttLength |
根据数据的总长度,计算出剩余的数据长度信息 According to the total length of the data, calculate the remaining data length information | |
CheckConnectBack |
根据服务器返回的信息判断当前的连接是否是可用的 According to the information returned by the server to determine whether the current connection is available | |
CheckMqttTopicWildcards |
判断当前服务器的实际的 topic 的主题,是否满足通配符格式的订阅主题 subTopic
| |
Equals | Determines whether the specified object is equal to the current object. (继承自 Object。) | |
ExtraIntFromBytes |
从MQTT的缓存信息里,提取长度信息 Extract length information from MQTT cache information | |
ExtraMqttReceiveData |
解析从MQTT接受的客户端信息,解析成实际的Topic数据及Payload数据 Parse the client information received from MQTT and parse it into actual Topic data and Payload data | |
ExtraMsgFromBytes |
从MQTT的缓存信息里,提取文本信息 Extract text information from MQTT cache information | |
ExtraSubscribeMsgFromBytes |
从MQTT的缓存信息里,提取文本信息 Extract text information from MQTT cache information | |
Finalize | Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection. (继承自 Object。) | |
GetHashCode | Serves as the default hash function. (继承自 Object。) | |
GetMqttCodeText |
获取当前的错误的描述信息 Get a description of the current error | |
GetMqttSyncServicesApiFromMethod |
根据当前的方法的委托信息和类对象,生成MqttRpcApiInfo的API对象信息。
| |
GetMqttSyncServicesApiFromProperty |
根据当前的方法的委托信息和类对象,生成MqttRpcApiInfo的API对象信息。
| |
GetSyncServicesApiInformationFromObject(Object) |
根据当前的对象定义的方法信息,获取到所有支持ApiTopic的方法列表信息,包含API名称,示例参数数据,描述信息。 According to the method information defined by the current object, the list information of all methods that support ApiTopic is obtained, including the API name, sample parameter data, and description information. | |
GetSyncServicesApiInformationFromObject(String, Object, HslMqttPermissionAttribute) |
根据当前的对象定义的方法信息,获取到所有支持ApiTopic的方法列表信息,包含API名称,示例参数数据,描述信息。 According to the method information defined by the current object, the list information of all methods that support ApiTopic is obtained, including the API name, sample parameter data, and description information. | |
GetType | Gets the Type of the current instance. (继承自 Object。) | |
HandleObjectMethod(MqttSession, MqttClientApplicationMessage, MqttRpcApiInfo) |
使用指定的对象来返回网络的API接口,前提是传入的数据为json参数,返回的数据为json数据,详细参照说明 Use the specified object to return the API interface of the network, provided that the incoming data is json parameters and the returned data is json data, please refer to the description for details | |
HandleObjectMethod(MqttSession, MqttClientApplicationMessage, Object) |
使用指定的对象来返回网络的API接口,前提是传入的数据为json参数,返回的数据为json数据,详细参照说明 Use the specified object to return the API interface of the network, provided that the incoming data is json parameters and the returned data is json data, please refer to the description for details | |
MemberwiseClone | Creates a shallow copy of the current Object. (继承自 Object。) | |
ReceiveMqttFile |
使用MQTT协议从网络接收字节数组,然后写入文件或流中,支持进度报告 Use MQTT protocol to receive byte array from the network, and then write it to file or stream, support progress report | |
ReceiveMqttFileAsync |
使用MQTT协议从网络接收字节数组,然后写入文件或流中,支持进度报告 Use MQTT protocol to receive byte array from the network, and then write it to file or stream, support progress report | |
ReceiveMqttMessage(CommunicationPipe, Int32, ActionInt64, Int64) |
接收一条完整的MQTT协议的报文信息,包含控制码和负载数据 Receive a message of a completed MQTT protocol, including control code and payload data | |
ReceiveMqttMessageT(FuncT, Int32, Int32, ActionInt64, Int64, OperateResultByte, T, Int32, ActionInt64, Int64) |
接收一条完整的MQTT协议的报文信息,包含控制码和负载数据 Receive a message of a completed MQTT protocol, including control code and payload data | |
ReceiveMqttMessageAsync(CommunicationPipe, Int32, ActionInt64, Int64) |
接收一条完整的MQTT协议的报文信息,包含控制码和负载数据 Receive a message of a completed MQTT protocol, including control code and payload data | |
ReceiveMqttMessageAsyncT(FuncT, Int32, Int32, ActionInt64, Int64, TaskOperateResultByte, T, Int32, ActionInt64, Int64) |
接收一条完整的MQTT协议的报文信息,包含控制码和负载数据 Receive a message of a completed MQTT protocol, including control code and payload data | |
ReceiveMqttRemainingLength(CommunicationPipe) |
基于MQTT协议,从网络套接字中接收剩余的数据长度 Receives the remaining data length from the network socket based on the MQTT protocol | |
ReceiveMqttRemainingLengthT(FuncT, Int32, Int32, ActionInt64, Int64, OperateResultByte, T) |
基于MQTT协议,从网络套接字中接收剩余的数据长度 Receives the remaining data length from the network socket based on the MQTT protocol | |
ReceiveMqttRemainingLengthAsync(CommunicationPipe) |
基于MQTT协议,从网络套接字中接收剩余的数据长度 Receives the remaining data length from the network socket based on the MQTT protocol | |
ReceiveMqttRemainingLengthAsyncT(FuncT, Int32, Int32, ActionInt64, Int64, TaskOperateResultByte, T) |
基于MQTT协议,从网络套接字中接收剩余的数据长度 Receives the remaining data length from the network socket based on the MQTT protocol | |
ReceiveMqttStream |
使用MQTT协议从socket接收指定长度的字节数组,然后全部写入到流中,可以指定进度报告 Use the MQTT protocol to receive a byte array of specified length from the socket, and then write all of them to the stream, and you can specify a progress report | |
ReceiveMqttStreamAsync |
使用MQTT协议从socket接收指定长度的字节数组,然后全部写入到流中,可以指定进度报告 Use the MQTT protocol to receive a byte array of specified length from the socket, and then write all of them to the stream, and you can specify a progress report | |
SendMqttFile(CommunicationPipe, Stream, String, String, ActionInt64, Int64, AesCryptography, HslCancelToken) |
使用MQTT协议将一个数据流发送到网络上去,需要保存的文件名,可选指定文件描述信息,进度报告 Use the MQTT protocol to send a data stream to the network, the file name that needs to be saved, optional file description information, progress report | |
SendMqttFile(CommunicationPipe, String, String, String, ActionInt64, Int64, AesCryptography, HslCancelToken) |
使用MQTT协议将一个文件发送到网络上去,需要指定文件名,保存的文件名,可选指定文件描述信息,进度报告 To send a file to the network using the MQTT protocol, you need to specify the file name, the saved file name, optionally specify the file description information, and the progress report | |
SendMqttFileAsync(CommunicationPipe, Stream, String, String, ActionInt64, Int64, AesCryptography, HslCancelToken) |
使用MQTT协议将一个数据流发送到网络上去,需要保存的文件名,可选指定文件描述信息,进度报告 Use the MQTT protocol to send a data stream to the network, the file name that needs to be saved, optional file description information, progress report | |
SendMqttFileAsync(CommunicationPipe, String, String, String, ActionInt64, Int64, AesCryptography, HslCancelToken) |
使用MQTT协议将一个文件发送到网络上去,需要指定文件名,保存的文件名,可选指定文件描述信息,进度报告 To send a file to the network using the MQTT protocol, you need to specify the file name, the saved file name, optionally specify the file description information, and the progress report | |
SendMqttStream |
使用MQTT协议将流中的数据读取到字节数组,然后都写入到socket里面,可以指定进度报告,主要用于将文件发送到网络。 Use the MQTT protocol to read the data in the stream into a byte array, and then write them all into the socket. You can specify a progress report, which is mainly used to send files to the network. | |
SendMqttStreamAsync |
使用MQTT协议将流中的数据读取到字节数组,然后都写入到socket里面,可以指定进度报告,主要用于将文件发送到网络。 Use the MQTT protocol to read the data in the stream into a byte array, and then write them all into the socket. You can specify a progress report, which is mainly used to send files to the network. | |
ToString | Returns a string that represents the current object. (继承自 Object。) |
名称 | 说明 | |
---|---|---|
ToJsonString |
获取当前对象的JSON格式表示的字符串。 (由 HslExtension 定义。)Gets the string represented by the JSON format of the current object. |