C# ActiveX开发及安装部署

  1 using System;   2 using System.Collections.Generic;   3 using System.Windows.Forms;   4 using System.IO.Ports;   5 using System.IO;   6 using System.Reflection;   7 using System.Runtime.InteropServices;   8 using mshtml;   9 using System.Text;  10 using Microsoft.Win32;  11 using System.Threading;  12   13 namespace WebSerial  14 {  15     [ProgId("WebSerial")]//控件名称  16     [ClassInterface(ClassInterfaceType.AutoDual), ComSourceInterfaces(typeof(ControlEvents))]  17     [Guid("6C6A0DE4-193A-48f5-BA91-3C180558785B")]//控件的GUID，用于COM注册和HTML中Object对象classid引用  18     [ComVisible(true)]  19     public partial class SerialPortControl : UserControl,IObjectSafety  20     {  21         ExSerialPort serialPort;  22         List<byte> buffer = new List<byte>(4096);  23   24         /// <summary>  25         /// 是否准备关闭串口  26         /// </summary>  27         private static bool m_IsTryToClosePort = false;  28         /// <summary>  29         /// 是否正在接收数据  30         /// </summary>  31         private static bool m_IsReceiving = false;  32         public SerialPortControl()  33         {  34   35         }  36   37         /// <summary>  38         /// 获取本地串口列表，以逗号隔开  39         /// </summary>  40         /// <returns></returns>  41         public string getComPorts()  42         {  43             string ports = "";  44             foreach (string s in ExSerialPort.GetPortNames())  45             {  46                 ports += "," + s;  47             }  48             return ports.Length > 0 ? ports.Substring(1) : "";  49         }  50   51         /// <summary>  52         /// 以指定串口号和波特率连接串口  53         /// </summary>  54         /// <param name="com">端口号</param>  55         /// <param name="baudRate">波特率</param>  56         /// <returns></returns>  57         [ComVisible(true)]  58         public string connect(string com, int baudRate)  59         {  60             close();  61             serialPort = null;  62             serialPort = new ExSerialPort(com);  63             serialPort.BaudRate = baudRate;  64             serialPort.Parity = Parity.None;  65             serialPort.DataBits = 8;  66             serialPort.Encoding = Encoding.ASCII;  67             serialPort.ReceivedBytesThreshold = 5;  68             serialPort.ReadBufferSize = 102400;  69   70             try  71             {  72                 serialPort.Open();  73                 if (serialPort.IsOpen)  74                 {  75                     m_IsTryToClosePort = false;  76                     this.clear();  77                     serialPort.DataReceived += new SerialDataReceivedEventHandler(serialPort_DataReceived);  78                     return "true";  79                 }  80             }  81             catch { }  82   83             return "false";  84         }  85   86         /// <summary>  87         /// 清理串口数据并关闭串口  88         /// </summary>  89         [ComVisible(true)]  90         public void close()  91         {  92             m_IsTryToClosePort = true;  93             while (m_IsReceiving)  94             {  95                 Application.DoEvents();  96             }  97   98             if (serialPort != null)  99             { 100                 serialPort.Dispose(); 101             } 102         } 103  104         /// <summary> 105         /// 清理串口数据 106         /// </summary> 107         [ComVisible(true)] 108         public void clear() 109         { 110             if (serialPort != null && serialPort.IsOpen) 111             { 112                 serialPort.Clear(); 113             } 114         } 115  116         /// <summary> 117         /// 发送字符串 118         /// </summary> 119         /// <param name="s"></param> 120         [ComVisible(true)] 121         public void writeString(string hexString) 122         { 123             if (serialPort != null && serialPort.IsOpen) 124             { 125                 byte[] bytes = strToToHexByte(hexString); 126                 serialPort.Write(bytes, 0, bytes.Length); 127             } 128         } 129  130         /// <summary> 131         /// 字符串转16进制字节数组 132         /// </summary> 133         /// <param name="hexString"></param> 134         /// <returns></returns> 135         private static byte[] strToToHexByte(string hexString) 136         { 137             hexString = hexString.Replace(" ", ""); 138             if ((hexString.Length % 2) != 0) 139                 hexString += " "; 140             byte[] returnBytes = new byte[hexString.Length / 2]; 141             for (int i = 0; i < returnBytes.Length; i++) 142                 returnBytes[i] = Convert.ToByte(hexString.Substring(i * 2, 2), 16); 143             return returnBytes; 144         } 145  146         ///  <summary>   147         /// 字节数组转字符串16进制   148         ///  </summary>   149         ///  <param name="InBytes"> 二进制字节 </param>   150         ///  <returns>类似"01 02 0F" </returns>   151         public static string ByteToString(byte[] InBytes) 152         { 153             string StringOut = ""; 154             foreach (byte InByte in InBytes) 155             { 156                 //StringOut += String.Format("{0:X2}", InByte) + " ";   157                 StringOut += " " + InByte.ToString("X").PadLeft(2, '0'); 158             } 159  160             return StringOut.Trim(); 161         } 162  163         /// <summary> 164         /// 接收数据 165         /// </summary> 166         /// <param name="sender"></param> 167         /// <param name="e"></param> 168         void serialPort_DataReceived(object sender, SerialDataReceivedEventArgs e) 169         { 170             if (m_IsTryToClosePort) 171             { 172                 return; 173             } 174  175             m_IsReceiving = true; 176  177             try 178             { 179                 int n = serialPort.BytesToRead; 180                 if (n > 0) 181                 { 182                     byte[] buf = new byte[n]; 183                     serialPort.Read(buf, 0, n); 184                     string dataString = ByteToString(buf); 185                     Receive(dataString); 186                 } 187  188                 ////1.缓存数据 189                 //buffer.AddRange(buf); 190                 ////2.完整性判断 191                 //while (buffer.Count >= 5) //至少包含帧头（2字节）、长度（1字节）、校验位（1字节）；根据设计不同而不同 192                 //{ 193                 //    //2.1 查找数据头 194                 //    if (buffer[0] == 0xff && buffer[1] == 0x55) //传输数据有帧头，用于判断 195                 //    { 196                 //        int len = buffer[2]; 197                 //        if (buffer.Count < len + 4) //数据区尚未接收完整 198                 //        { 199                 //            break; 200                 //        } 201                 //        //得到完整的数据，复制到ReceiveBytes中进行校验 202                 //        byte[] ReceiveBytes = new byte[len + 4]; 203                 //        buffer.CopyTo(0, ReceiveBytes, 0, len + 4); 204  205                 //        byte checkByte = ReceiveBytes[len + 3];//获取校验字节 206                 //        byte realCheckByte = 0x00; 207                 //        realCheckByte -= buffer[2]; 208                 //        for (int packIndex = 0; packIndex < len; packIndex++)//将后面的数据加起来 209                 //        { 210                 //            realCheckByte -= ReceiveBytes[packIndex + 3]; 211                 //        } 212  213                 //        if (checkByte == realCheckByte)//验证，看数据是否合格 214                 //        { 215                 //            string dataString = ByteToString(ReceiveBytes);                             216                 //            Receive(dataString); 217                 //        } 218                 //        buffer.RemoveRange(0, len + 4); 219                 //    } 220                 //    else //帧头不正确时，清除 221                 //    { 222                 //        buffer.RemoveAt(0); 223                 //    } 224  225                 //} 226             } 227             finally 228             { 229                 m_IsReceiving = false; 230             } 231         } 232  233         public event ControlEventHandler OnReceive; 234         [ComVisible(true)] 235         private void Receive(string dataString) 236         { 237             if (OnReceive != null) 238             { 239                 OnReceive(dataString); //Calling event that will be catched in JS 240             } 241         } 242  243         ///    <summary> 244         ///    Register the class as a    control    and    set    it's CodeBase entry 245         ///    </summary> 246         ///    <param name="key">The registry key of the control</param> 247         [ComRegisterFunction()] 248         public static void RegisterClass(string key) 249         { 250             // Strip off HKEY_CLASSES_ROOT/ from the passed key as I don't need it 251             StringBuilder sb = new StringBuilder(key); 252  253             sb.Replace(@"HKEY_CLASSES_ROOT/", ""); 254             // Open the CLSID/{guid} key for write access 255             RegistryKey k = Registry.ClassesRoot.OpenSubKey(sb.ToString(), true); 256  257             // And create    the    'Control' key -    this allows    it to show up in 258             // the ActiveX control container 259             RegistryKey ctrl = k.CreateSubKey("Control"); 260             ctrl.Close(); 261  262             // Next create the CodeBase entry    - needed if    not    string named and GACced. 263             RegistryKey inprocServer32 = k.OpenSubKey("InprocServer32", true); 264             inprocServer32.SetValue("CodeBase", Assembly.GetExecutingAssembly().CodeBase); 265             inprocServer32.Close(); 266             // Finally close the main    key 267             k.Close(); 268             MessageBox.Show("Registered"); 269         } 270  271         ///    <summary> 272         ///    Called to unregister the control 273         ///    </summary> 274         ///    <param name="key">Tke registry key</param> 275         [ComUnregisterFunction()] 276         public static void UnregisterClass(string key) 277         { 278             StringBuilder sb = new StringBuilder(key); 279             sb.Replace(@"HKEY_CLASSES_ROOT/", ""); 280  281             // Open    HKCR/CLSID/{guid} for write    access 282             RegistryKey k = Registry.ClassesRoot.OpenSubKey(sb.ToString(), true); 283  284             // Delete the 'Control'    key, but don't throw an    exception if it    does not exist 285             k.DeleteSubKey("Control", false); 286  287             // Next    open up    InprocServer32 288             //RegistryKey    inprocServer32 =  289             k.OpenSubKey("InprocServer32", true); 290  291             // And delete the CodeBase key,    again not throwing if missing 292             k.DeleteSubKey("CodeBase", false); 293  294             // Finally close the main key 295             k.Close(); 296             MessageBox.Show("UnRegistered"); 297         } 298  299         #region IObjectSafety 成员 300         public void GetInterfacceSafyOptions(int riid, out int pdwSupportedOptions, out int pdwEnabledOptions) 301         { 302             pdwSupportedOptions = 1; 303             pdwEnabledOptions = 2; 304         } 305         public void SetInterfaceSafetyOptions(int riid, int dwOptionsSetMask, int dwEnabledOptions) 306         { 307             throw new NotImplementedException(); 308         } 309         #endregion 310  311         #region IObjectSafety 成员 312  313         private const string _IID_IDispatch = "{00020400-0000-0000-C000-000000000046}"; 314         private const string _IID_IDispatchEx = "{a6ef9860-c720-11d0-9337-00a0c90dcaa9}"; 315         private const string _IID_IPersistStorage = "{0000010A-0000-0000-C000-000000000046}"; 316         private const string _IID_IPersistStream = "{00000109-0000-0000-C000-000000000046}"; 317         private const string _IID_IPersistPropertyBag = "{37D84F60-42CB-11CE-8135-00AA004BB851}"; 318  319         private const int INTERFACESAFE_FOR_UNTRUSTED_CALLER = 0x00000001; 320         private const int INTERFACESAFE_FOR_UNTRUSTED_DATA = 0x00000002; 321         private const int S_OK = 0; 322         private const int E_FAIL = unchecked((int)0x80004005); 323         private const int E_NOINTERFACE = unchecked((int)0x80004002); 324  325         private bool _fSafeForScripting = true; 326         private bool _fSafeForInitializing = true; 327  328  329         public int GetInterfaceSafetyOptions(ref Guid riid, ref int pdwSupportedOptions, ref int pdwEnabledOptions) 330         { 331             int Rslt = E_FAIL; 332  333             string strGUID = riid.ToString("B"); 334             pdwSupportedOptions = INTERFACESAFE_FOR_UNTRUSTED_CALLER | INTERFACESAFE_FOR_UNTRUSTED_DATA; 335             switch (strGUID) 336             { 337                 case _IID_IDispatch: 338                 case _IID_IDispatchEx: 339                     Rslt = S_OK; 340                     pdwEnabledOptions = 0; 341                     if (_fSafeForScripting == true) 342                         pdwEnabledOptions = INTERFACESAFE_FOR_UNTRUSTED_CALLER; 343                     break; 344                 case _IID_IPersistStorage: 345                 case _IID_IPersistStream: 346                 case _IID_IPersistPropertyBag: 347                     Rslt = S_OK; 348                     pdwEnabledOptions = 0; 349                     if (_fSafeForInitializing == true) 350                         pdwEnabledOptions = INTERFACESAFE_FOR_UNTRUSTED_DATA; 351                     break; 352                 default: 353                     Rslt = E_NOINTERFACE; 354                     break; 355             } 356  357             return Rslt; 358         } 359  360         public int SetInterfaceSafetyOptions(ref Guid riid, int dwOptionSetMask, int dwEnabledOptions) 361         { 362             int Rslt = E_FAIL; 363  364             string strGUID = riid.ToString("B"); 365             switch (strGUID) 366             { 367                 case _IID_IDispatch: 368                 case _IID_IDispatchEx: 369                     if (((dwEnabledOptions & dwOptionSetMask) == INTERFACESAFE_FOR_UNTRUSTED_CALLER) && 370                          (_fSafeForScripting == true)) 371                         Rslt = S_OK; 372                     break; 373                 case _IID_IPersistStorage: 374                 case _IID_IPersistStream: 375                 case _IID_IPersistPropertyBag: 376                     if (((dwEnabledOptions & dwOptionSetMask) == INTERFACESAFE_FOR_UNTRUSTED_DATA) && 377                          (_fSafeForInitializing == true)) 378                         Rslt = S_OK; 379                     break; 380                 default: 381                     Rslt = E_NOINTERFACE; 382                     break; 383             } 384  385             return Rslt; 386         } 387  388         #endregion 389     } 390  391     /// <summary> 392     /// Event handler for events that will be visible from JavaScript 393     /// </summary> 394     public delegate void ControlEventHandler(string dataString); 395  396     /// <summary> 397     /// This interface shows events to javascript 398     /// </summary> 399     [Guid("68BD4E0D-D7BC-4cf6-BEB7-CAB950161E79")] 400     [InterfaceType(ComInterfaceType.InterfaceIsIDispatch)] 401     public interface ControlEvents 402     { 403         //Add a DispIdAttribute to any members in the source interface to specify the COM DispId. 404         [DispId(0x60020001)] 405         void OnReceive(string dataString); //This method will be visible from JS 406     } 407  408     public class ExSerialPort : SerialPort 409     { 410         public ExSerialPort(string name) 411             : base(name) 412         { 413         } 414  415         public void Clear() 416         { 417             try 418             { 419                 if (this.IsOpen) 420                 { 421                     this.DiscardInBuffer(); 422                     this.DiscardOutBuffer(); 423                 } 424             } 425             catch { } 426         } 427  428         protected override void Dispose(bool disposing) 429         { 430             Clear(); 431  432             var stream = (Stream)typeof(SerialPort).GetField("internalSerialStream", BindingFlags.Instance | BindingFlags.NonPublic).GetValue(this); 433  434             if (stream != null) 435             { 436                 stream.Dispose(); 437             } 438  439             base.Dispose(disposing); 440         } 441     } 442 }

  1 <html>    2 <head>    3 <title>JavaScript串口测试</title>   4 <meta http-equiv="Content-Type" content="text/html; charset=GB2312" />   5 <script   language="javascript"   type="text/javascript">    6 <!--    7     function getComPorts()   8     {   9         var ports = webSerial.getComPorts();  10         var arr = ports.split(',');  11         var ctl = document.getElementById("ComName");   12         if(ctl)   13         {   14             ctl.options.length = 0;  15             for(var i=0;i<arr.length;i++)  16             {  17                 ctl.options[i] = new Option(arr[i],arr[i]);   18             }  19         }   20    }  21       22     function connectComPort()  23     {  24         var com = document.getElementById("ComName").value.toString();  25         var baudRate = document.getElementById("BaudRate").value;  26         var result = webSerial.connect(com,baudRate);  27         alert(result);  28     }  29       30     function clearComPort()  31     {  32         webSerial.clear();  33         alert("清理串口成功!");  34     }  35       36     function closeComPort()  37     {  38         webSerial.close();  39         alert("关闭串口成功!");  40     }  41       42     function writeString()  43     {  44         var hexString = document.getElementById("txtSend").value.toString();   45         webSerial.writeString(hexString);  46         alert("发送指令成功!");  47     }   48       49     function clearSend()  50     {  51         document.getElementById("txtSend").innerText="";  52     }  53       54     function clearReceive()  55     {  56         document.getElementById("txtReceive").innerText="";  57     }  58       59     function startTime()  60     {  61         var today=new Date()  62         var h=today.getHours()  63         var m=today.getMinutes()  64         var s=today.getSeconds()  65         // add a zero in front of numbers<10  66         m=checkTime(m)  67         s=checkTime(s)  68         document.getElementById('lblTime').innerHTML=h+":"+m+":"+s  69         t=setTimeout('startTime()',500)  70     }  71   72     function checkTime(i)  73     {  74         if (i<10)   75           {i="0" + i}  76           return i  77     }  78   79 -->   80 </script>     81   82 </head>   83 <body onload="startTime()" onunload="closeComPort()">  84 <form name="form1">       85 <fieldset style="width:225px;height:180px;text-align:center;">  86    <legend>串口</legend>  87    <div style="float:left;width:250px">     88        <br/>     89        <span>串口号:</span>  90        <select name="ComName" id="ComName" style="width:100px" >    91        </select>  92        <br/>     93        <span>波特率:</span>  94    <select name="BaudRate" id="BaudRate" style="width:100px" >  95    <option value="9600" selected="selected">9600</option>  96    <option value="57600"  >57600</option>  97    <option value="115200" >115200</option>     98    <option value="1382400" >1382400</option>    99    <option value="3000000" >3000000</option>   100    </select>    101    <br/> 102        <br/> 103        <input   type="button" id="btnGetPort" style="width:80px;height:30px;font-size:13px"   name="btnGetPort"   value="获取串口"   onclick="getComPorts()"/>        104        <input   type="button" id="btnOpenPort" style="width:80px;height:30px;font-size:13px"   name="btnOpenPort"   value="打开串口"   onclick="connectComPort()"/>      105        <input   type="button" id="btnClearPort" style="width:80px;height:30px;font-size:13px"   name="btnClearPort"   value="清理串口"   onclick="clearComPort()"/>          106        <input   type="button" id="btnClosePort" style="width:80px;height:30px;font-size:13px"   name="btnClosePort"   value="关闭串口"   onclick="closeComPort()"/>        107     </div>  108 </fieldset> 109 <br /><br /> 110 <fieldset style="width:800px;height:150px;text-align:center;"> 111    <legend>发送区域</legend> 112    <div align="left">V6-握手指令： FF 55 01 01 FE</div> 113    <div align="left">V6-50HZ采集：FF 55 05 03 20 4E 00 00 8A</div> 114    <div align="left">V6-停止指令： FF 55 01 10 EF</div> 115    <div style="float:left;"> 116        <textarea id="txtSend"  name="txtSend" style="width:800px;height:80px"></textarea>  117        <br/> 118        <input   type="button" id="btnSend" style="width:100px;height:30px"   name="btnSend"   value="发送"   onclick="writeString()"/>    119        <input  type="button" id="btnClearSend" style="width:100px;height:30px"   name="btnClearSend"   value="清空"   onclick="clearSend()"/> 120    </div>  121 </fieldset> 122 <br /><br /> 123 <fieldset style="width:800px;height:500px;text-align:center;"> 124    <legend>接收区域</legend>    125    <div style="float:left;"> 126    <textarea id="txtReceive"  readonly="readonly" name="txtReceive" style="width:800px;height:430px"></textarea>   127    <br/> 128    <input  type="button" id="btnClearReceive" style="width:100px;height:30px"   name="btnClearReceive"   value="清空"   onclick="clearReceive()"/> 129    </div> 130 </fieldset>    131 <span id="lblTime"></span> 132 </form>  133  134 <p> 135  136 <object classid="clsid:6C6A0DE4-193A-48f5-BA91-3C180558785B" codebase="../WebSerialSetup.msi" width="442" height="87" id="webSerial" name="webSerial"> 137         </object> 138 </p> 139  140  <!-- Attaching to an ActiveX event--> 141 <script language="javascript" type="text/javascript"> 142     function webSerial::OnReceive(dataString) 143     { 144         document.getElementById("txtReceive").value += dataString+"/r/n";;    145     } 146 </script> 147 </body>  148 </html>