程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> .NET網頁編程 >> 關於.NET >> 《連載 | 物聯網框架ServerSuperIO教程》- 11.實現設備(驅動)與設備(驅動)交互和級聯控制。注:設備驅動模擬金三與普京的對話,serversuperio

《連載 | 物聯網框架ServerSuperIO教程》- 11.實現設備(驅動)與設備(驅動)交互和級聯控制。注:設備驅動模擬金三與普京的對話,serversuperio

編輯:關於.NET

《連載 | 物聯網框架ServerSuperIO教程》- 11.實現設備(驅動)與設備(驅動)交互和級聯控制。注:設備驅動模擬金三與普京的對話,serversuperio


1.C#跨平台物聯網通訊框架ServerSuperIO(SSIO)介紹

《連載 | 物聯網框架ServerSuperIO教程》1.4種通訊模式機制。

《連載 | 物聯網框架ServerSuperIO教程》2.服務實例的配置參數說明

《連載 | 物聯網框架ServerSuperIO教程》- 3.設備驅動介紹

《連載 | 物聯網框架ServerSuperIO教程》-4.如開發一套設備驅動,同時支持串口和網絡通訊。

《連載 | 物聯網框架ServerSuperIO教程》- 5.輪詢通訊模式開發及注意事項。

《連載 | 物聯網框架ServerSuperIO教程》- 6.並發通訊模式開發及注意事項

《連載 | 物聯網框架ServerSuperIO教程》- 7.自控通訊模式開發及注意事項

《連載 | 物聯網框架ServerSuperIO教程》- 8.單例通訊模式開發及注意事項

《連載 | 物聯網框架ServerSuperIO教程》- 9. 協議過濾器,解決一包多發、粘包、冗余數據

《連載 | 物聯網框架ServerSuperIO教程》- 10.持續傳輸大塊數據流的兩種方式(如:文件)


 

目       錄

11.實現設備(驅動)與設備(驅動)級聯控制... 2

11.1         概述... 2

11.2         設備鏈接器... 2

11.3         場景假設... 3

11.4         設備驅動開發及注意事項... 3

11.5         宿主程序服務實例配置注意事項... 5

11.6         運行效果... 6

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     設備驅動開發及注意事項

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

11.6     運行效果

      1.圖片


  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved