网络通讯控制器分组，提高交互的负载平衡能力实例教程

static void Main(string[] args)

{

    string deviceID = "2";

    DeviceDriver dev3 = new DeviceDriver();

    dev3.DeviceParameter.DeviceName = "设备2";

    dev3.DeviceParameter.DeviceAddr = 0;

    dev3.DeviceParameter.DeviceID = deviceID;

    dev3.DeviceParameter.DeviceCode = deviceID;

    dev3.DeviceDynamic.DeviceID = deviceID;

    dev3.DeviceParameter.NET.RemoteIP = "127.0.0.1";

    dev3.DeviceParameter.NET.RemotePort = 9600;

    dev3.DeviceParameter.NET.ControllerGroup = "G2";

    dev3.CommunicateType = CommunicateType.NET;

    dev3.DeviceParameter.NET.WorkMode = WorkMode.TcpServer;

    dev3.Initialize(deviceID);

    deviceID = "3";

    DeviceDriver dev4 = new DeviceDriver();

    dev4.DeviceParameter.DeviceName = "设备3";

    dev4.DeviceParameter.DeviceAddr = 0;

    dev4.DeviceParameter.DeviceID = deviceID;

    dev4.DeviceParameter.DeviceCode = deviceID;

    dev4.DeviceDynamic.DeviceID = deviceID;

    dev4.DeviceParameter.NET.RemoteIP = "127.0.0.1";

    dev4.DeviceParameter.NET.RemotePort = 9600;

    dev4.DeviceParameter.NET.ControllerGroup = "G3";

    dev4.CommunicateType = CommunicateType.NET;

    dev4.Initialize(deviceID);

    IServer server = new ServerManager().CreateServer(new ServerConfig()

    {

        ServerName = "服务1",

        ComReadTimeout = 1000,

        ComWriteTimeout = 1000,

        NetReceiveTimeout = 1000,

        NetSendTimeout = 1000,

        ControlMode = ControlMode.Loop,

        SocketMode = SocketMode.Tcp,

        StartReceiveDataFliter = false,

        ClearSocketSession = true,

        StartCheckPackageLength = false,

        CheckSameSocketSession = false,

    });

    server.AddDeviceCompleted += server_AddDeviceCompleted;

    server.DeleteDeviceCompleted += server_DeleteDeviceCompleted;

    server.SocketConnected+=server_SocketConnected;

    server.SocketClosed+=server_SocketClosed;

    server.Start();

    server.AddDevice(dev3);

    server.AddDevice(dev4);

    while ("exit"==Console.ReadLine())

    {

         server.Stop();

    }

}