11．實現設備（驅動）與設備（驅動）級聯控制

11.1 概述

物聯網建設中數據採集是基礎，進行控制是目的，這是兩個根本要素。在採集設備數據的時候，如果該設備的實時數據出現異常，那麼是否存在其他設備要進行聯動？也就是說一個設備出現異常之後，要對其他某個設備進行聯動控制，以達到避免出現更大危險的情況。

那麼不僅要對某個設備進行聯動控制，還要對控制的結果進行反饋給出現異常的設備。形成異常、聯動、控制、反饋的閉環，以達到監測與控制共同作用的目的。

11.2 設備鏈接器

IRunDevice設備驅動介面繼承了IDeviceConnector設備鏈接器介面，以便使設備驅動與設備驅動之間可以雙向交互，實現數據傳遞與命令控制的目的。介面的定義如下：

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);
}

通過這個介面定義，可以得知通過OnDeviceConnector事件觸發信息傳遞的起始端，會把信息傳遞給接收信息端設備驅動的RunDeviceConnector介面函數，執行完RunDeviceConnector函數後，會把結果數據返回給發送端設備驅動的DeviceConnectorCallback介面函數，如果接收數據端設備驅動執行RunDeviceConnector過程中出現異常，則會調用發起端設備驅動的DeviceConnectorCallbackError介面函數，至此整個流程結束。

11.3 場景假設

0號設備驅動的名稱叫金三，1號設備驅動的名稱叫普京。金三得知南韓樸大媽事件後，問普京：大哥，樸大媽為什麼還不下課？。普京回答：你不覺得這才是真正的韓劇嗎？傻小子。金三說：奧黑也真夠坑爹的！完成整個流程的信息傳遞。

11.4 設備驅動開發及註意事項

金三接到信息後，發起信息傳遞。觸發OnDeviceConnector事件，並把IDeviceToDevice介面deviceCode參數設置為1，指向傳遞給普京。代碼如下：

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) );
                }
            }
        }

2.普京接收到信息後，進行信息解析後，並返回他的意思（結果）。代碼如下：

public override object RunDeviceConnector(IFromDevice fromDevice, IDeviceToDevice toDevice)
        {
            Console.WriteLine(toDevice.Text);//輸出其他設備傳來的數據。
            return this.DeviceParameter.DeviceName + "答：你不覺得這才是真正的韓劇嗎？傻小子";
        }

3.金三接收到普京的返回信息後，把矛頭指向了奧黑。代碼如下：

public override void DeviceConnectorCallback(object obj)
        {
            Console.WriteLine(obj.ToString());//輸出返回結果
            Console.WriteLine(this.DeviceParameter.DeviceName+ "說：奧黑也真夠坑爹的！");
            Console.WriteLine(">>>>模擬控制命令結束");
        }

註：這裡並沒有用到DeviceConnectorCallbackError執行異常返回介面函數。

11.5 宿主程式服務實例配置註意事項

這是用自控模式實現的，設備驅動並沒有主動發送數據。代碼如下：

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();
            }
        }