ModBus TCP 連線

  
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.Net;

using System.Net.Sockets;



namespace ServiceRequestData

{

    class ConnectDevice

    {

        public string Value = ""; //向Device要回的資料

        public bool TimeOut = false; //是否有TimeOut發生

      

        //與Device連線

        public ConnectDevice(string hostip,int port,int func,string startaddress,int length)

        {

            byte[] senddata = SendModbusCommend(func, startaddress, length); //傳送的資料

            byte[] recvdata = SocketConnectCommend(hostip,port,senddata); //傳送後接收回來的資料

            Value = RecvModbusCommend(recvdata);





        }

      

        //Modbus傳送指令 fuction,StartAddress,Length

        //支援func:1,2,3,4

        //StartAddress:"0f ff"

        //length:wordcount,bitcount

        private byte[] SendModbusCommend(int func, string StartAddress, int length)

        {

            byte[] refnum = new byte[2];

            byte[] count = new byte[2];

            byte[] Commend = new byte[12];

            refnum = strToHexByte(StartAddress);

            count = BitConverter.GetBytes(length);

            for (int i = 0; i < Commend.Length; i++)

                switch (i)

                {

                    case 5:

                        Commend[i] = Convert.ToByte(6); //封包後面長度

                        break;

                    case 6:

                        Commend[i] = Convert.ToByte(1);

                        break;

                    case 7:

                        Commend[i] = Convert.ToByte(func); //function

                        break;

                    case 8:

                        Commend[i] = refnum[0]; //startaddress

                        break;

                    case 9:

                        Commend[i] = refnum[1];

                        break;

                    case 10:

                        Commend[i] = count[1]; //length

                        break;

                    case 11:

                        Commend[i] = count[0];

                        break;

                    default:

                        Commend[i] = Convert.ToByte(0);

                        break;



                }



            return Commend;



        }

      

        //Modbus接收指令

        //傳回字串型態Bytes

        private string RecvModbusCommend(byte[] recvcmd)

        {

          

            byte [] data = new byte[recvcmd[8]];

            for (int i = 9; i < recvcmd.Length; i++)

            data[i-9] = recvcmd[i];



            return byteToHexStr(data);

          

        }



        //TCP同步傳輸：傳送指令後接收資料

        private byte[] SocketConnectCommend(string host, int port, byte[] sendBytes) 

        {

            //int port = Convert.ToInt32("502");

            //string host = "192.168.1.204";

            IPAddress ip = IPAddress.Parse(host);

            IPEndPoint ipe = new IPEndPoint(ip, port);

            Socket sk = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            //byte[] sendBytes = strToHexByte("00 00 00 00 00 06 01 05 00 01 00 01 00");

            byte[] recvBytes = new byte[256];



            try

            {



                sk.Connect(ipe);

                sk.Send(sendBytes, sendBytes.Length, 0);

                sk.Receive(recvBytes, recvBytes.Length, 0);

                sk.Close();

                return recvBytes;

            }

            catch (ArgumentNullException ex)

            {

                MessageBox.Show(ex.ToString());

                TimeOut = true;

                return null;

            }

            catch (SocketException ex)

            {

                MessageBox.Show(ex.ToString());

                TimeOut = true;

                return null;

            }

        }





        //十六進位轉成字串 0x00 0x01 0x0f 0xff "00 01 0f ff"

        private static string byteToHexStr(byte[] bytes)

        {

            string returnStr = "";

            if (bytes != null)

            {

                for (int i = 0; i < bytes.Length; i++)

                {

                    returnStr += bytes[i].ToString("X2") + " ";

                }

            }

            return returnStr;

        }



        //字串轉成Byte陣列 "00 01 0f ff" 0x00 0x01 0x0f 0xff

        private static byte[] strToHexByte(string hexString)

        {

            hexString = hexString.Replace(" ", "");

            if ((hexString.Length % 2) != 0)

                hexString += " ";

            byte[] returnBytes = new byte[hexString.Length / 2];

            for (int i = 0; i < returnBytes.Length; i++)

                returnBytes[i] = Convert.ToByte(hexString.Substring(i * 2, 2), 16);

            return returnBytes;

        }



      



            }

        }

  

C# 連結MySQL 搜尋,新增,刪除,修改

需到MySQL官方網站下載DLL檔 

連結如下 Connector/Net

並加入參考MySql.Data.dll (2.0)


程式如下

using System;

using System.Collections.Generic;

using System.Text;

using System.Windows.Forms;

using System.Diagnostics;

using System.IO;

using System.Data;

//加入mysql 類別庫

using MySql.Data;

using MySql.Data.MySqlClient;




namespace ServiceRequestData

{

    class ConnectDatabase

    {




        private string serverAddress;

        private string databaseName;

        private string userID;

        private string password;

        private MySqlConnection MysqlConnection;




        public ConnectDatabase()

        {

            Initialize();

        }




        //資料初始化

        private void Initialize()

        {

            serverAddress = "";//localhost

            databaseName = "";

            userID = "";

            password = "";

            string connectionString;

            connectionString = "SERVER=" + serverAddress + ";DATABASE=" + databaseName + ";UID=" + userID + ";PWD=" + password;

            MysqlConnection = new MySqlConnection(connectionString);




        }







        //開啟連結到資料庫

        private bool ConnectionOpen()

        {

            try

            {




                MysqlConnection.Open();




                return true;

            }

            catch (MySqlException ex)

            {

                //例外處理，常見的兩種錯誤

                //ex.Number=0:無法連接到伺服器.

                //ex.Number=1045: 無效的使用者名稱或密碼.

                switch (ex.Number)

                {

                    case 0:

                        MessageBox.Show("無法連接到伺服器");

                        break;

                    case 1042:

                        MessageBox.Show("無效的主機名稱");

                        break;

                    case 1045:

                        MessageBox.Show("使用者名稱/密碼錯誤");

                        break;

                }

                return false;

            }

        }




        //關閉連結

        private bool ConnectionClose()

        {

            try

            {

                MysqlConnection.Close();

                return true;

            }

            catch (MySqlException ex)

            {

                MessageBox.Show(ex.Message);

                return false;

            }

            catch (Exception ex)

            {

                MessageBox.Show(ex.Message);

                return false;

            }

        }




        

        //執行新增刪除修改語法

        public void ExeSQL(string SQLstatement) //SQLstatement:SQL語法

        {

             

            //open connection

            if (this.ConnectionOpen() == true)//開啟連結

            {

                MySqlCommand command = new MySqlCommand(SQLstatement, MysqlConnection);//new MySQL 指令




                command.ExecuteNonQuery();//執行語法




                this.ConnectionClose();//關掉連結

            }

        }




        //執行查詢語法，將結果放入Dataset中

        public void SelectRead(string SQLstatement,ref DataSet ds, string TableName) 

        {




            if (this.ConnectionOpen() == true)//開啟連結

            {

                MySqlCommand command = new MySqlCommand(SQLstatement, MysqlConnection);//new MySQL 指令

                MySqlDataAdapter sdt = new MySqlDataAdapter(command); 

                sdt.Fill(ds, TableName); //把查詢結果Table放入dataset

                this.ConnectionClose();//關掉連結

            }

            

            

        }







    }

}