《连载 | 物联网框架ServerSuperIO教程》- 11.实现设备（驱动）与设备（驱动）交互和级联控制。注：设备驱动模拟金三与普京的对话

public interface IDeviceConnector
{
/// <summary>
/// 支行设备连接器
/// </summary>
/// <param name="fromDevice">信息传递的发送端</param>
/// <param name="toDevice">信息传递的目的端，以及包含的数据信息</param>
/// <returns></returns>
object RunDeviceConnector(IFromDevice fromDevice, IDeviceToDevice toDevice); /// <summary>
/// 设备连接器回调函数，在这里写回调的处理结果
/// </summary>
/// <param name="obj"></param>
void DeviceConnectorCallback(object obj); /// <summary>
/// 如果执行方出现异常，则返回给这个函数结果
/// </summary>
/// <param name="ex"></param>
void DeviceConnectorCallbackError(Exception ex); /// <summary>
/// 连接器事件，发起端
/// </summary>
event DeviceConnectorHandler DeviceConnector; /// <summary>
/// 确发事件接口
/// </summary>
/// <param name="fromDevice"></param>
/// <param name="toDevice"></param>
void OnDeviceConnector(IFromDevice fromDevice, IDeviceToDevice toDevice);
}

public override void Communicate(ServerSuperIO.Communicate.IRequestInfo info)
{
byte[] cmds = this.Protocol.GetCommand(info.Data);
CommandArray cr = (CommandArray)cmds[0];
dynamic obj = this.Protocol.DriverAnalysis<byte[]>(cr.ToString(), info.Data, info.BigData);
if (obj != null)
{
if (cr == CommandArray.RealTimeData)
{
_deviceDyn.Dyn = (Dyn)obj;
OnDeviceRuningLog("通讯正常"); Console.WriteLine(">>>>模拟控制命令开始");
this.OnDeviceConnector(new FromDevice(this.DeviceParameter.DeviceID,this.DeviceParameter.DeviceCode,this.DeviceParameter.DeviceAddr,this.DeviceParameter.DeviceName),new DeviceToDevice("1",this.DeviceParameter.DeviceName+"问：大哥，朴大妈为什么还不下课？",null,null) );
}
}
}

public override object RunDeviceConnector(IFromDevice fromDevice, IDeviceToDevice toDevice)
{
Console.WriteLine(toDevice.Text);//输出其他设备传来的数据。
return this.DeviceParameter.DeviceName + "答：你不觉得这才是真正的韩剧吗？傻小子";
}

public override void DeviceConnectorCallback(object obj)
{
Console.WriteLine(obj.ToString());//输出返回结果
Console.WriteLine(this.DeviceParameter.DeviceName+ "说：奥黑也真够坑爹的！");
Console.WriteLine(">>>>模拟控制命令结束");
}

static void Main(string[] args)
{
DeviceSelfDriver dev1 = new DeviceSelfDriver();
dev1.DeviceParameter.DeviceName = "金三";
dev1.DeviceParameter.DeviceAddr = 0;
dev1.DeviceParameter.DeviceID = "0";
dev1.DeviceDynamic.DeviceID = "0";
dev1.DeviceParameter.DeviceCode = "0";
dev1.DeviceParameter.COM.Port = 1;
dev1.DeviceParameter.COM.Baud = 9600;
dev1.DeviceParameter.NET.RemoteIP = "127.0.0.1";
dev1.DeviceParameter.NET.RemotePort = 9600;
dev1.CommunicateType = CommunicateType.NET;
dev1.Initialize("0"); DeviceSelfDriver dev2 = new DeviceSelfDriver();
dev2.DeviceParameter.DeviceName = "普京";
dev2.DeviceParameter.DeviceAddr = 1;
dev2.DeviceParameter.DeviceID = "1";
dev2.DeviceDynamic.DeviceID = "1";
dev2.DeviceParameter.DeviceCode = "1";
dev2.DeviceParameter.NET.RemoteIP = "127.0.0.1";
dev2.DeviceParameter.NET.RemotePort = 9600;
dev2.CommunicateType = CommunicateType.NET;
dev2.Initialize("1"); IServer server = new ServerManager().CreateServer(new ServerConfig()
{
ServerName = "服务1",
ComReadTimeout = 1000,
ComWriteTimeout = 1000,
NetReceiveTimeout = 1000,
NetSendTimeout = 1000,
ControlMode = ControlMode.Self,
SocketMode = SocketMode.Tcp,
StartReceiveDataFliter = true,
ClearSocketSession = false,
StartCheckPackageLength = true,
CheckSameSocketSession = false,
DeliveryMode = DeliveryMode.DeviceCode,
}); server.AddDeviceCompleted += server_AddDeviceCompleted;
server.DeleteDeviceCompleted+=server_DeleteDeviceCompleted;
server.Start(); server.AddDevice(dev1);
server.AddDevice(dev2); while ("exit" == Console.ReadLine())
{
server.Stop();
}
}