定义 ModemManager 调度管理类
ModemManager 类用于对所有 Modem 对象进行管理和调度使用。ModemManager 类代码如下:
using System;using System.Collections.Generic;using System.Text;using System.IO.Ports;using System.Threading;namespace RequestResponse001CS{ // 拨号器管理者 public class ModemManager { //已经安装了拨号器的串口对象 private ListmodemCollection = null; // ModemCollection 的调度编号 private int modemNumber = -1; //当前有无可使用的串口拨号器 private bool hasEnabled = false; //串口拨号器的重新检测间隔分钟 private int reCheckMinutes = 30; //默认30分钟 //波特率配置列表 private Dictionary boudrateCollection = null; //获得当前时间 private DateTime checkDateTime = DateTime.Now; private ManagerCallback m_callBack = null; //返回委托事件 #region 委托 public delegate void ManagerCallback(String message); //委托返回信息 private void ReturnMessage(String message) { if (message.Length > 0 && m_callBack != null) { m_callBack(message); } } #endregion #region 属性 public List ModemCollection { get { return modemCollection; } } //可使用的拨号器个数 public int EnabledCount { get { if (modemCollection == null) return 0; else return modemCollection.Count; } } public bool HasEnabled { get { return hasEnabled; } //set { hasPort = value; } } //波特率配置列表 public Dictionary BoudrateCollection { get { return boudrateCollection; } set { boudrateCollection = value; } } //串口拨号器的重新检测间隔分钟 public int ReCheckMinutes { get { return reCheckMinutes; } set { reCheckMinutes = value; } } #endregion #region 构造方法 public ModemManager(ManagerCallback callBack) { if (callBack != null) m_callBack = callBack; } public ModemManager(int reCheckMinutes, ManagerCallback callBack) { this.ReCheckMinutes = reCheckMinutes; if (callBack != null) m_callBack = callBack; } public ModemManager(Dictionary boudrateCollection, ManagerCallback callBack) { this.BoudrateCollection = boudrateCollection; if (callBack != null) m_callBack = callBack; } public ModemManager(Dictionary boudrateCollection, int reCheckMinutes,ManagerCallback callBack) { this.BoudrateCollection = boudrateCollection; this.ReCheckMinutes = reCheckMinutes; if (callBack != null) m_callBack = callBack; } #endregion 构造方法 #region 调度方法 /// /// 调用拨号器 /// /// public void ModemInvoking(string cardNumber) { if (hasEnabled == false) { // 获得串口上已经安装了拨号器的对象 this.GetModemCollection(); } if (hasEnabled == true) { this.ModemCalling(cardNumber); } //定期检测串口列表 if (checkDateTime.AddMinutes(ReCheckMinutes) <= DateTime.Now) { // 重新获得串口上已经安装了拨号器的对象 this.GetModemCollection(); checkDateTime = DateTime.Now; } } ////// 获得串口上安装了拨号器的对象 /// public void GetModemCollection() { if (modemCollection == null) { modemCollection = new List(); } int modemCollectionCount = modemCollection.Count; //步骤一: 重新获得所有的串口名称(列表) string[] portNames = SerialPort.GetPortNames(); //如果当前串口数目 > 正在使用的COM if (portNames.Length > modemCollectionCount) { ReturnMessage("正在检测可以使用的拨号器..."); //测试使用 foreach (string portName in portNames) { //当前串口名是否存在拨号列表中 bool existModem = false; if (modemCollectionCount > 0) { existModem = modemCollection.Exists(delegate(Modem myModem) { return portName == myModem.PortName; }); } //如果当前串口名不存在拨号列表中,则重新检测! if (!existModem) { ReturnMessage("正在检测:" + portName); //测试使用 AddModemToCollection(portName); } } } // 判断当前计算机有无可使用串口端 hasEnabled = modemCollection.Count <= 0 ? false : true; } /// /// 对拨号器的调度使用 /// private void ModemCalling(string cardNumber) { if (modemCollection == null) return; // 等待线程进入 Monitor.Enter(modemCollection); Modem modem = null; try { //获得当前调用的串口对象的索引号 int number = GetModemNumber(); if (number >= 0) //判断是否存在拨号器 { modem = modemCollection[number]; if (modem != null) // && !modem.IsWorking) { ReturnMessage(string.Format("{0} 正在对 SIM卡:{1} 进行拨号...", modem.PortName,cardNumber)); modem.DialingNumberToModem(cardNumber); //对 SIM 进行拨号,唤醒上位机 } } else { ReturnMessage("没有可使用的拨号器,重新对端口进行检测..."); this.GetModemCollection(); } } catch { //再一次检查该 COM 能否使用! (范工提议) if (modem != null) { string portName = modem.PortName; modemCollection.Remove(modem); //从可用列表去除 modem.CloseModem(); AddModemToCollection(portName); } } finally { if (modemCollection != null) { // 通知其它对象 Monitor.Pulse(modemCollection); // 释放对象锁 Monitor.Exit(modemCollection); } } } ////// 获得对 ModemCollection 的调度编号 /// ///private int GetModemNumber() { lock (this) { if (modemNumber + 1 >= modemCollection.Count) { if (modemCollection.Count == 0) modemNumber = -1; else modemNumber = 0; } else { modemNumber++; } return modemNumber; } } /// /// 添加 Modem 到 modemCollection /// private void AddModemToCollection(string portName) { Modem myModem = null; //是否设置波特率? if (boudrateCollection != null && boudrateCollection.ContainsKey(portName) && boudrateCollection[portName] != 0) { myModem = new Modem(portName, boudrateCollection[portName], ReturnMessage); } else { myModem = new Modem(portName, ReturnMessage); } bool hasModem = myModem.CheckPortExistModem(); if (hasModem) { modemCollection.Add(myModem); } else { myModem.CloseModem(); myModem = null; } } ////// 释放所有的串口资源 /// public void CloseModemCollection() { if (modemCollection != null) { for (int i = 0; i < modemCollection.Count; i++) { modemCollection[i].CloseModem(); modemCollection[i] = null; } modemCollection = null; } if (boudrateCollection != null) { boudrateCollection = null; } } #endregion }}
定义 FormModemManager 测试界面类
测试界面 FormModemManager 类用于对 ModemManager 对象进行测试,代码如下:
using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Text;using System.Windows.Forms;using System.Threading;namespace RequestResponse001CS{ public partial class FormModemManager : Form { public FormModemManager() { InitializeComponent(); } ModemManager ModemManager; Thread thread; private void FormModemManager_Load(object sender, EventArgs e) { ModemManager = new ModemManager(5, TakeControl); } public void TakeControl(string message) { if (this.InvokeRequired) { Modem.SetCallback d = new Modem.SetCallback(TakeControl); this.Invoke(d, new object[] { message }); } else { //MessageBox.Show(message); this.txtMessageShow.Text = this.txtMessageShow.Text + message + "\r\n" ; this.txtMessageShow.Select(this.txtMessageShow.Text.Length, 0); this.txtMessageShow.ScrollToCaret(); } } private void FormModemManager_FormClosing(object sender, FormClosingEventArgs e) { if (thread != null) { thread.Abort(); } } private void Button_Run_Click(object sender, EventArgs e) { thread = new Thread(new ThreadStart(Run)); thread.Start(); } private void Run() { try { // 获得串口上已经安装了拨号器的对象 ModemManager.GetModemCollection(); if (ModemManager.HasEnabled == false) { TakeControl("当前计算机无可使用的串口拨号器!"); } else { TakeControl("当前计算机可使用的拨号器如下:"); ListmodemCollection = ModemManager.ModemCollection; for (int i = 0; i < modemCollection.Count; i++) { Modem modem = modemCollection[i]; TakeControl(string.Format("端口名:{0},波特率:{1}", modem.PortName, modem.Boudrate.ToString())); } } while (ModemManager.HasEnabled) { // 调用拨号器 if (string.IsNullOrEmpty(txtCardNumber.Text.Trim())) { ModemManager.ModemInvoking("135xxxxxxxx"); // SIM 卡号 } else ModemManager.ModemInvoking(txtCardNumber.Text.Trim()); Thread.Sleep(5000); } TakeControl("程序运行结束!"); } finally { // 释放所有串口资源组件 ModemManager.CloseModemCollection(); } } //运行停止 private void Button_Stop_Click(object sender, EventArgs e) { if (ModemManager != null) { ModemManager.CloseModemCollection(); } } }}
测试页面截图如下:
本文转自钢钢博客园博客,原文链接:http://www.cnblogs.com/xugang/archive/2013/05/13/3075992.html,如需转载请自行联系原作者