работа с несколькими COM портами

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
//-----
using System.IO.Ports;
using System.IO;


namespace comSobitie
{
    public partial class Form1 : Form
    {
        
        // Таймер
        Timer timer = new Timer();
        // Порт
        SerialPort port = new SerialPort("COM2", 9600, System.IO.Ports.Parity.None, 8, System.IO.Ports.StopBits.One);
        string valu = "";
        String indata = "";
        public Form1()
        {
            InitializeComponent();
           System.Windows.Forms.Control.CheckForIllegalCrossThreadCalls = false;  //ОЧЕНЬ СПОРНОЕ РЕШЕНИЕ !!!!!!!!!!
            // Подписались на приход данных
            port.DataReceived += new SerialDataReceivedEventHandler(port_DataReceived);

            // Задаем интервал таймеру
            timer.Interval = 10000;
            // Подписываемся на тики таймера
            timer.Tick += new EventHandler(timer1_Tick);
            // Стартуем таймер
            timer.Start(); 
        }

        private void Form1_Load(object sender, EventArgs e)
        {

        }

        private void timer1_Tick(object sender, EventArgs e)
        {
            // Открываем порт
            if (port.IsOpen)
            {
                // Если порт открыт, значит какой-то косяк, девайс не ответил, здесь обрабатываем

                // Закрываем
                port.Close();
            }

            // Открываем
            port.Open();

            // Чето посылаем
            port.Write("#10\r");
        }
        int i = 0;
        // Пришли данные
        void port_DataReceived(object sender, SerialDataReceivedEventArgs e)
        {
                 System.Threading.Thread.Sleep(100);
                // Получаем пришедшие данные
                indata = port.ReadExisting();
                
                // Чето с ними делаем

                textBox1.Text = " SELECT  \"ID_TagName\"" + indata + " ;";
      
                // Закрываем порт
                if (port.IsOpen) port.Close();                      
           
        }

    }
}

 /// <summary>
    /// Класс работы с последовательным портом
    /// </summary>
    public class SerialPort : IDisposable
    {
        //--------------------------------------------------------------------------
        //Construction, Destruction
        //--------------------------------------------------------------------------
        #region Construction, Destruction
        /// <summary>
        /// Оболочка для работы с СОМ-портом
        /// </summary>
        /// <param name="comNum">Номер СОМ-порта</param>
        /// <param name="baudRate">Скорость</param>
        public SerialPort(byte comNum, int baudRate)
        {
            this.comNum = comNum;
            serialPort = new System.IO.Ports.SerialPort("COM" + comNum.ToString(), baudRate);
            serialPort.Open();
            thread = new System.Threading.Thread(ThreadFn);
            thread.Start();
        }
        
        /// <summary>
        /// Очистка ресурсов
        /// </summary>
        public void Dispose()
        {
            DisposeImpl(true);
        }
        
        /// <summary>
        /// Finalizer
        /// </summary>
        ~SerialPort()
        {
            DisposeImpl(false);
        }

        private void DisposeImpl(bool manualDispose)
        {
            if (manualDispose)
            {
                if (thread != null)
                    thread.Abort();
                if (serialPort != null)
                    serialPort.Dispose();
            }
        }
        #endregion Construction, Destruction

        //--------------------------------------------------------------------------
        //Public Interface
        //--------------------------------------------------------------------------
        #region Public Interface
        /// <summary>
        /// Отправить данные
        /// </summary>
        /// <param name="data">Массив данных</param>
        /// <exception cref="Exception">Генерируется, если при работе с последовательным портом
        /// возникнет исключение</exception>
        public void SendData(Byte[] data)
        {
            serialPort.Write(data, 0, data.Length);
        }
        
        /// <summary>
        /// Текущий номер СОМ-порта
        /// </summary>
        public Byte ComNum
        {
            get { return comNum; }
            set
            {
                if (comNum != value)
                {
                    comNum = value;
                    serialPort.Close();
                    serialPort.PortName = "COM" + value.ToString();
                }
            }
        }

        /// <summary>
        /// Скорость передачи данных
        /// </summary>
        public int BaudRate
        {
            get { return serialPort.BaudRate; }
            set { serialPort.BaudRate = value; }
        }
        /// <summary>
        /// Состояние линии Dtr
        /// </summary>
        public bool DtrEnable
        {
            get { return serialPort.DtrEnable; }
            set { serialPort.DtrEnable = value; }
        }
        /// <summary>
        /// Состояние линии Rts
        /// </summary>
        public bool RtsEnable
        {
            get { return serialPort.RtsEnable; }
            set { serialPort.RtsEnable = value; }
        }

        /// <summary>
        /// Делегат приема байта
        /// </summary>
        /// <param name="data">Принятый байт данных</param>
        public delegate void OnByteReceived(Byte data);

        /// <summary>
        /// Событие приема байт
        /// </summary>
        public event OnByteReceived ByteReceived;
        #endregion Public Interface

        //--------------------------------------------------------------------------
        //Private Member Functions
        //--------------------------------------------------------------------------
        #region Private Member Functions
        //Обработка принятого байта
        private void OnReceiveByte(Byte data)
        {
            //Если на событие приема байт кто-то подписан, то отправляю ему байт
            if (ByteReceived != null)
                ByteReceived(data);
        }
        //Функция чтения данных в новом потоке
        private void ThreadFn(object obj)
        {
            //создаю входной буффер. Сюда будут писаться данные из последовательного порта
            Byte[] inputBuffer = new Byte[inputBufferSize];
            while (true)
            {

                try
                {
                    //получаю количество доступных байт
                    int availibleBytes = serialPort.BytesToRead;
                    if (availibleBytes > 0)
                    {
                        int bytesToRead = availibleBytes < inputBufferSize ? availibleBytes : inputBufferSize;
                        int readedBytes = serialPort.Read(inputBuffer, 0, bytesToRead);
                        for (int i = 0; i < readedBytes; i++)
                            OnReceiveByte(inputBuffer[i]);
                    }
                    System.Threading.Thread.Sleep(1);
                }
                catch (System.Threading.ThreadAbortException)
                {
                    break;
                }
                catch (Exception e)
                {
                    System.Diagnostics.Debug.Assert(false, e.Message);
                }
            }
        }
        #endregion Private Member Functions

        //--------------------------------------------------------------------------
        //Private Data Members
        //--------------------------------------------------------------------------
        #region Private Data Members
        /// <summary>
        /// Номер СОМ-порта
        /// </summary>
        private Byte comNum;
        /// <summary>
        /// Последовательный порт
        /// </summary>
        private System.IO.Ports.SerialPort serialPort;
        /// <summary>
        /// Поток. Нужен, т.к. данные читаются в новом потоке
        /// </summary>
        private System.Threading.Thread thread;
        /// <summary>
        /// Максимальный размер входного буффер
        /// </summary>
        private const int inputBufferSize = 1024;

        #endregion Private Data Members
    }//class RS232

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO.Ports;
using System.Windows.Forms;
using System.Data;

namespace COMSpectators
{
	class Program
	{

		static Timer mainTimer;
		
		static DataSet ds3;

		static DataTable dt3;
		
		static List<OneCOMSpectator> allListeners;

		static void Main(string[] args)
		{
			InitAll();

			NpgsqlConnection conn = new NpgsqlConnection(("Server=" + list[0] + ";Port=" + list[1] + ";User Id=" + list[2] + ";Password=" + list[3] + ";Database=" + list[4] + ";"));  //
			string sql = " SELECT  \"ID_TagName\", \"ID_RealHardWare\",   \"F_ParseFunction\",   \"F_ComQuery\",   \"F_AnswerLenght\",   \"F_AnswerKey\",   \"F_AnswerKeyPosition\",   \"F_ComPort\",   \"F_ComPortIPAdress\",   \"F_ComPortBaudRate\",   \"F_ComPortParity\",   \"F_ComPortDataBits\",   \"F_ComPortStopBit\",   \"F_ComPortFlowControl\",   \"F_ComPortTimeOut\" ,  \"ID_HardWareTag\",   \"F_OPCServerName\",   \"F_IDOPCTag\", \"F_TagReadTime\",   \"Transmit\",   \"F_RealHardWare_ID\" FROM  \"SC_Tag\".\"T_TagName\" as tn,\"SC_Tag\".\"T_HardWareTag\" as hw , \"SC_Tag\".\"T_RealHardWare\" as rh where  rh.\"ID_RealHardWare\" = hw.\"F_RealHardWare_ID\"  and tn.\"F_HardWare_ID\" = hw.\"F_TagName_ID\"   and \"F_ServerName\"  =\'" + Environment.MachineName + "\' and \"F_ComPortIPAdress\" = \'127.0.0.1\' ";
			//   string sql = "  SELECT \"F_name\", \"F_OPCServerName\", \"F_IDOPCTag\", \"F_TagReadTime\",  \"ID_TagName\"   FROM \"SC_Tag\".\"T_TagName\" as tn, \"SC_Tag\".\"T_HardWareTag\" as hw  where tn.\"F_HardWare_ID\" = hw.\"ID_HardWareTag\"    and \"F_ServerName\"  =\'" + Environment.MachineName + "\' ";

			NpgsqlDataAdapter da3 = new NpgsqlDataAdapter(sql, conn);

			ds3.Reset();
			da3.Fill(ds3);
			dt3 = ds3.Tables[0];
			dataGridView3.DataSource = dt3;


			int mainInterval = 1000;//Convert.ToInt32(dt3.Rows[0][14]);
			mainTimer = new Timer();
			mainTimer.Interval = mainInterval;

			mainTimer.Enabled = true;
			mainTimer.Tick+=new EventHandler(mainTimer_Tick);


		}

		static void  mainTimer_Tick(object sender, EventArgs e)
		{
 			foreach(OneCOMSpectator comListener in allListeners)
			{
				comListener.TransferData();
			}
		}



		private static void InitAll()
		{

			allListeners = new List<OneCOMSpectator>();

			for(int xx = 0; xx < ds3.Tables[0].Rows.Count; ++xx)
			{
				string com = "COM" + dt3.Rows[xx][7];
				string send = dt3.Rows[xx][3].ToString() + "\r";


				allListeners.Add(new OneCOMSpectator(com, 9600, send));
			}


		}
	}


	class OneCOMSpectator
	{
		SerialPort _COM;
		string DataToSend;

		internal OneCOMSpectator(string portNumber, int bodRate, string dataTosend)
		{
			DataToSend = dataTosend;
			_COM = new SerialPort(portNumber, bodRate, System.IO.Ports.Parity.None, 8, System.IO.Ports.StopBits.One);
			_COM.DataReceived += new SerialDataReceivedEventHandler(_COM_DataReceived);
		}

		void _COM_DataReceived(object sender, SerialDataReceivedEventArgs e)
		{
			// Пришли данные
		}


		internal void TransferData()
		{
			if(_COM.IsOpen)
			{
				// Если порт открыт, значит какой-то косяк, девайс не ответил, здесь обрабатываем

				// Закрываем
				_COM.Close();
			}

			// Открываем
			_COM.Open();

			_COM.Write(DataToSend);
			
		}

	
	}

}