1.插件库的导入 CommunationPlugs.cs
public void Load() { DirectoryInfo di = new DirectoryInfo(AppDomain.CurrentDomain.BaseDirectory); foreach (FileInfo fi in di.GetFiles("Communication.*.dll")) //这步意味着我们只要按这个名字格式编写新的通讯接口，就能在此处导入。 { Assembly lib = Assembly.LoadFrom(fi.FullName); foreach (Type t in lib.GetExportedTypes()) { if (t.GetInterface(typeof(ICommunicationPlug).FullName) != null) { ICommunicationPlug plug = (ICommunicationPlug)Activator.CreateInstance(t); InitializePlugin(Env.Current, plug); } } } }
2.下面按照runtime的流程，将关键函数罗列出来
MainForm.cs下运行按钮 private void OnRunClick(object sender, System.EventArgs e) { if(windowManager.StartRuntime()) { runButton.Enabled = false; refreshButton.Enabled = false; stopButton.Enabled = true; } } WindowManager.cs下 public bool StartRuntime() { if (Env.Current.CommunicationPlugins.Connect()) //通讯接口连接看下面CommunationPlugs.cs { if (ArchiverMain.Current.DatabaseSettings.EnableArchiving) { if (ArchiverMain.Current.Start() == false) //写入数据库线程，看下面Archiver.cs { Env.Current.CommunicationPlugins.Disconnect(); return false; } } return true; } return false; } CommunationPlugs.cs下 public bool Connect() { foreach (ICommunicationPlug plug in commPlugs) //有多少插件，每个都处理一次 { bool connectResult = false; try { connectResult = plug.Connect();//打开该通讯接口下的线程，看各通讯接口Plugin.cs } catch (Exception e) { Env.Current.Logger.LogError(StringResources.msgFailedToConnectPlugins); Env.Current.Logger.LogError(e.Message); return false; } if (connectResult == false) { Env.Current.Logger.LogError(StringResources.msgFailedToConnectPlugins); Disconnect(); return false; } } return true; } Archiver.cs下 public bool Start() { dbWriter = new DbWriter(); if (dbWriter.Open() == false) return false; channelUpdaterThread = new Thread(new ParameterizedThreadStart(ChannelUpdaterThreadProc)); channelUpdaterThread.Start(this); dbReader = new DbReader(); if (dbReader.Open() == false) return false; return IsRunning; } ChannelUpdaterThreadProc(object obj) 写数据库线程 Plugin.cs下 connect为开启此插件下所有station线程 // 开启station线程 modbus public bool Connect() { if (IsConnected) return false; System.GC.Collect(); if (channels.Count > 0) { foreach (IModbusStation stat in stations) stat.Start();//开启station线程 } connectedFlag = true; return IsConnected; } ///将chanel压入队列 public void SendValueUpdateToModbusLine(ModbusChannelImp ch) { if (runThread) { lock (sendQueueSyncRoot) protected object sendQueueSyncRoot = new object(); { sendQueue.Enqueue(ch); } sendQueueEndWaitEvent.Set();/// protected ManualResetEvent sendQueueEndWaitEvent = new ManualResetEvent(false); } }
初步理了下，还在进一步研究中！
