MqttRpcDevice 类

public class MqttRpcDevice : MqttSyncClient, 
	IReadWriteDevice, IReadWriteNet

Public Class MqttRpcDevice
	Inherits MqttSyncClient
	Implements IReadWriteDevice, IReadWriteNet

public ref class MqttRpcDevice : public MqttSyncClient, 
	IReadWriteDevice, IReadWriteNet

type MqttRpcDevice =  
    class
        inherit MqttSyncClient
        interface IReadWriteDevice
        interface IReadWriteNet
    end

// 以下是举例子，将两个PLC和一个Modbus的对象注册为RPC接口

private MqttServer server;
private MelsecMcNet melsec;
private SiemensS7Net siemens;
private ModbusRtu modbus;

public void Start( )
{
    melsec = new MelsecMcNet( "192.168.0.100", 6000 );                // ip及端口需要改成你自己实际的参数

    siemens = new SiemensS7Net( SiemensPLCS.S1200, "192.168.0.101" ); // ip需要改成你自己实际的参数

    modbus = new ModbusRtu( 1 );                                      // 指定站号实例化
    modbus.SerialPortInni( "COM2", 9600 );                            // 初始化串口信息
    modbus.DataFormat = HslCommunication.Core.DataFormat.CDAB;        // 根据实际情况设置

    server = new MqttServer( );
    server.ClientVerification += Server_ClientVerification;           // 启动账户密码，如果不需要验证，则注释即可

    server.RegisterMqttRpcApi( "MelsecPLC", melsec );                 // API分类随便写，方便客户端指定就行，需要唯一
    server.RegisterMqttRpcApi( "SiemensPLC", siemens );               // API分类随便写，方便客户端指定就行，需要唯一
    server.RegisterMqttRpcApi( "Modbus", modbus );                    // API分类随便写，方便客户端指定就行，需要唯一

    server.ServerStart( 1883 );                                       // 启动服务
}

private int Server_ClientVerification( MqttSession mqttSession, string clientId, string userName, string passwrod )
{
    // 这里举例只能账户密码登录
    // if (userName == "admin" && passwrod == "123456") return 0;
    // else return 1;

    //不校验用户名密码
    return 0;
}

// 我们接下来在客户端访问当前的数据信息
private MqttRpcDevice rpcMelsec = new MqttRpcDevice( new MqttConnectionOptions( )
{
    IpAddress = "127.0.0.1",    // 服务器的IP地址
    Port = 1883,
    Credentials = new MqttCredential( "admin", "123456" ),  // 如果配置了用户名密码
    UseRSAProvider = true,                                  // 是否加密通信
},
    "MelsecPLC" );

private MqttRpcDevice rpcSiemens = new MqttRpcDevice( new MqttConnectionOptions( )
{
    IpAddress = "127.0.0.1",    // 服务器的IP地址
    Port = 1883,
    Credentials = new MqttCredential( "admin", "123456" ),  // 如果配置了用户名密码
    UseRSAProvider = true,                                  // 是否加密通信
},
    "SiemensPLC" );

private MqttRpcDevice rpcModbus = new MqttRpcDevice( new MqttConnectionOptions( )
{
    IpAddress = "127.0.0.1",    // 服务器的IP地址
    Port = 1883,
    Credentials = new MqttCredential( "admin", "123456" ),  // 如果配置了用户名密码
    UseRSAProvider = true,                                  // 是否加密通信
},
    "Modbus" );

public void Example( )
{
    // 就可以进行读取了，例如读取三菱设备的D100的short值
    OperateResult<short> read1 = rpcMelsec.ReadInt16( "D100" );
    OperateResult write1 = rpcMelsec.Write( "D100", (short)123 );

    // 例如读取西门设备的float值
    OperateResult<float> read2 = rpcSiemens.ReadFloat( "M100" );
    OperateResult write2 = rpcSiemens.Write( "M100", 1.23f );

    // Modbus设备读取int值
    OperateResult<int> read3 = rpcModbus.ReadInt32( "100" );
    OperateResult write3 = rpcModbus.Write( "100", 123 );

    // 用法上和普通的三菱，西门子，modbus是没有区别的。
}