網口串口(Serialport)服務器

文章所用工具
http://t.csdnimg.cn/2gIR8http://t.csdnimg.cn/2gIR8

搭建服務器界面

操作配置文件保存方式類

public string FileName {  get; set; }public IniHelper(string name) {this.FileName = name; //在構造函數中給路徑賦值}

1 先導入c語言進行讀取操作ini文件的方法

GetPrivateProfileString() 獲取ini配置文件的數據
? ? ? ? //static 靜態的變量只能聲明在當前文件中，不能在其他源文件進行使用。
? ? ? ? //extern 用來聲明外部的符號可以跨文件使用。

[DllImport("Kernel32.dll")] //導入方法所在dll文件
public static extern Int32 GetPrivateProfileString(string sectionName, //段名 string keyName,//鍵名string defaultName,//當鍵不存在默認值。StringBuilder returnValue,// 讀取到數據uint size,// 讀取數據的大小string fileName// ini文件路徑);

2添加寫入ini文件的c方法

[DllImport("Kernel32.dll")]
public static extern Int32 WritePrivateProfileString(string sectionName, //段名 string keyName,//鍵名string value,//設置的值string fileName// ini文件路徑);

不直接使用上面的倆個c語言的方法再封裝到其他方法進行使用
? ? ? ? //讀取ini數據的方法
? ? ? ? //ReadData("Second","B","Setting.ini") "10"
? ? ? ? //參數1 段名，參數2鍵名，參數3是文件路徑

public static string ReadData(string sectionName,string keyName,string fileName)
{StringBuilder sb = new StringBuilder(512); //512是存儲的大小GetPrivateProfileString(sectionName, keyName, string.Empty, sb, 512, fileName);return sb.ToString();
}

對上面ReadData再封裝，封裝能直接返回指定類型的數據的方法
? ? ? ? //傳進段名和鍵名獲取內容
? ? ? ? //以后Read("段名"，"鍵名") ?返回字符串類型

public string Read(string sectionName,string keyName)
{return ReadData(sectionName, keyName,this.FileName);}

如果讀取數據沒讀取到給賦一個初值
? ? ? ? Read("Secotion",A,"1000") ?最終結果：hello world
? ? ? ? Read("Secotion",C,"1000") ?最終結果：1000

 public string Read(string sectionName, string keyName,string defaultValue){string v = Read(sectionName, keyName);if (string.IsNullOrEmpty(v)){return defaultValue;}return v;}

讀取的時候返回一個整型的數據值

Read("Secotion",C,1000) ?最終結果：1000
Read("Secotion",A,1000) ?最終結果：1000

public int Read(string s1, string k1, int d1)
{string v = Read(s1, k1);if (int.TryParse(v,out int value)){return value;}else{return d1;}}

public bool Read(string s1, string k1, bool d1)
{string v = Read(s1, k1);if (bool.TryParse(v,out bool value)){return value;}else{//不能轉成boolif (v=="1"||v=="OK"||v=="ON"||v=="YES"){return true;}else if(v=="0"||v=="NO"||v=="OFF"||v.ToUpper()=="OFF"){//如果值以上幾種請求 值為falsereturn false;}else{return d1;}}
}
//ini值是double類型
public double Read(string s1, string k1, double d1)
{string v = Read(s1, k1);if (double.TryParse(v, out double value)){return value;}else{return d1;}}

封裝寫入數據的方法
先定義一個靜態寫入方法

public static  int WriteData(string s1,string k1,string v,string file)
{return WritePrivateProfileString(s1,k1,v,file);
}

封裝方法

//在封裝Write方法傳遞 傳進段名 鍵名 值是字符串
public int Write(string s1,string k1,string v1)
{return WriteData(s1, k1, v1, this.FileName);
}//在封裝Write方法傳遞 傳進段名 鍵名 值是整型
public int Write(string s1, string k1, int v1)
{return WriteData(s1, k1, v1.ToString(), this.FileName);
}//在封裝Write方法傳遞 傳進段名 鍵名 值是bool
public int Write(string s1, string k1, bool v1)
{return WriteData(s1, k1, v1?"1":"0", this.FileName);
}//在封裝Write方法傳遞 傳進段名 鍵名 值是時間格式
public int Write(string s1, string k1, DateTime v1)
{return WriteData(s1, k1, v1.ToString("yyyy-MM-dd HH-mm:ss"), this.FileName);
}

using調用?

編輯配置文件

存入File文件夾中，放到Dubug文件夾中

服務器

 IniHelper Ini;string[] botelvs = new string[] { "1200", "4800", "9600", "13200" };

1 讀取配置文件

string dirPath = Path.Combine(Application.StartupPath, "File"); // debug/File
string filePath = Path.Combine(dirPath, "Setting.ini");// debug / file/setting.ini
Ini = new IniHelper(filePath); // 創建讀取對象// 添加串口
comboBox1.Items.AddRange(SerialPort.GetPortNames()); // 獲取所有串口 拼接在下拉框的items中
comboBox2.Items.AddRange(botelvs); // 添加波特率數組
comboBox2.Items.Add("自定義");// 添加一個
comboBox3.Items.AddRange(new string[] { "5", "6", "7", "8" });
comboBox4.Items.AddRange(new string[] { "無", "奇校檢", "偶校檢" });
comboBox5.Items.AddRange(new string[] { "無", "1", "2", "1.5" });
// 2 開始處理邏輯串口接收數據的事件
// 處理串口的數據
this.serialPort1.DataReceived += SerialPort1_DataReceivd;// 3 處理界面顯示默認值 也就是從ini文件讀取數據
readStting();// 4 開始串口通信
startChuanKou();// 5 開始網口通信
startTCP();

開始搭建TCP 服務器

TcpListener listen;
List<TcpClient> lists = new List<TcpClient>(); // 存放所有的客戶端
void startTCP()
{if(!int.TryParse(textBox3.Text,out int port)||port < 1 || port > 65563){MessageBox.Show("請輸入正確的端口號");}// 開啟服務器 接受客戶端try{listen = new TcpListener(System.Net.IPAddress.Any, port);listen.Start(100); // 開始監聽panel2.BackColor = Color.Green;// 把多個客戶端接收到數組里面new Task(() =>{try{while (true){// 接受客戶端TcpClient c1 = listen.AcceptTcpClient();// 把客戶端添加到數組里面 群發需要lists.Add(c1);// 接受客戶端發來的消息tcpReceive(c1);}}catch{MessageBox.Show("TCP服務器關閉");}}).Start();}catch (Exception ex){MessageBox.Show("TCP啟動失敗");// 把tcp關閉等操作foreach(var item  in lists){item.Close(); // 關閉所有的客戶端}listen.Stop();panel2.BackColor = Color.Gray;}
}

接收數據

void tcpReceive(TcpClient c1)
{new Task(() =>{NetworkStream stream = c1.GetStream();try{MessageBox.Show("111");while (c1.Connected) // 當客戶端鏈接的時候{byte[] bs = new byte[1024];int length = stream.Read(bs, 0, bs.Length);if (length == 0) throw new Exception(); // 客戶端斷了// 接收到數據亮燈tcpLiangDeng();// 把數據轉給串口if (!serialPort1.IsOpen){MessageBox.Show("串口關閉");break;}// 把數據轉給串口 發送數據，com8能接收到消息，serialPort1.Write(bs, 0, length);}}catch{c1.Close();lists.Remove(c1);}}).Start();
}

亮燈

async void tcpLiangDeng()
{this.Invoke((Action)(() =>{textBox2.Text = (int.Parse(textBox2.Text) + 1).ToString();// 亮燈panel4.BackColor = Color.Pink;}));// 過一段時間await Task.Delay(70);this.Invoke((Action)(() =>{// 關燈panel4.BackColor = Color.Gray;}));
}

配置串口對象

void startChuanKou()
{// 配置串口對象try{this.serialPort1.PortName = comboBox1.Text;// 配置串口名稱this.serialPort1.BaudRate = int.Parse(comboBox2.Text); // 波特率this.serialPort1.DataBits = int.Parse(comboBox3.Text);this.serialPort1.StopBits = (StopBits)comboBox5.SelectedIndex; // 正常賦值 StopBits.NOne 枚舉值this.serialPort1.Parity = (Parity)comboBox4.SelectedIndex; //this.serialPort1.Open();// 亮燈this.panel1.BackColor = Color.Green;}catch{MessageBox.Show("打開串口失敗");// 停止串口if(serialPort1.IsOpen) serialPort1.Close();// 滅燈this.panel1.BackColor = Color.Gray;}}private void readStting()
{// 先配置串口comboBox1.SelectedItem = Ini.Read("Serialport", "name", "");string botelv = Ini.Read("Serialport", "botelv", "9601");int botelvIndex = Array.IndexOf(botelvs, botelv); // 獲取botelv在數組里面的索引值if (botelvIndex != -1){comboBox2.SelectedIndex = botelvIndex;}else{// 波特率在數組里面 自定義波特率情況comboBox2.DropDownStyle = ComboBoxStyle.DropDown; // 可編輯的下拉框// DropDownList 不可編輯的下拉框comboBox2.Text = botelv;}// 處理數據位comboBox3.SelectedItem = Ini.Read("Serialport", "databit", "8");// 處理奇偶校檢位comboBox4.SelectedIndex = Ini.Read("Serialport", "parity", 0);comboBox5.SelectedIndex = Ini.Read("Serialport", "stopbit", 0);comboBox1.DropDownStyle = ComboBoxStyle.DropDownList;comboBox3.DropDownStyle = ComboBoxStyle.DropDownList;comboBox4.DropDownStyle = ComboBoxStyle.DropDownList;comboBox5.DropDownStyle = ComboBoxStyle.DropDownList;// 網口數據的讀取textBox3.Text = Ini.Read("NetWork", "port", "8080");if (Ini.Read("NetWork", "heartOn", false)){radioButton1.Checked = true;}else{radioButton1.Checked = true;}textBox4.Text = Ini.Read("NetWork", "heartTime", "60000"); // 心跳間隔textBox5.Text = Ini.Read("NetWork", "heartTime", ""); // 心跳間隔checkBox1.Checked = Ini.Read("NetWork", "heartTime", false); // 心跳間隔}

接收串口傳遞的數據

private void SerialPort1_DataReceivd(object sender, SerialDataReceivedEventArgs e)
{byte[] bs = new byte[1024]; // 定義一個字節數組int count = serialPort1.Read(bs,0,bs.Length); // 讀取數據到字節數組if(count == 0){// 關閉窗口// 停止串口if (serialPort1.IsOpen) serialPort1.Close();// 滅燈this.panel1.BackColor = Color.Gray;}// 1 接收到一條窗口數據 需要panel3亮一次 分裝一個方法控制效果JieShouDaoChuanKou();// 2 轉發給所有的客戶端發消息 串口轉網口就是把串口數據通過網絡轉給其他客戶端foreach(var item in lists){item.GetStream().Write(bs,0,bs.Length);}}
async void JieShouDaoChuanKou()
{this.Invoke((Action)(() =>{textBox1.Text = (int.Parse(textBox1.Text) + 1).ToString();// 亮燈panel3.BackColor = Color.Pink;}));// 過一段時間await Task.Delay(70);this.Invoke((Action)(() =>{textBox1.Text = (int.Parse(textBox1.Text) + 1).ToString();// 關燈panel3.BackColor = Color.Gray;}));}

波特率下拉框出發變化的時候調用

private void comboBox2_SelectedIndexChanged(object sender, EventArgs e)
{if(comboBox2.SelectedItem.ToString() == "自定義"){// 切換到自定義選項上comboBox2.DropDownStyle = ComboBoxStyle.DropDown;}else{comboBox2.DropDownStyle = ComboBoxStyle.DropDownList;}
}

選中心跳開關為開的時候

private void radioButton1_CheckedChanged(object sender, EventArgs e)
{if(radioButton1.Checked){// 選中心跳timer1.Interval = string.IsNullOrEmpty(textBox4.Text) ? 6000 :  int.Parse(textBox4.Text);timer1.Tick += Timer1_Tick;timer1.Start();}
}

定時發送數據

private void Timer1_Tick(object sender, EventArgs e)
{// 定時發送數據string data = textBox5.Text; // 心跳數據 選中hex整明把2轉成16進制，byte[] buffer;if(checkBox1.Checked == true){// 需要發16進制的心跳string[] ds = data.Split(' '); //把2按照空格符號分割成數組結構[2]buffer = new byte[ds.Length]; // buffer數組長度就是ds的長度for(int i = 0; i < ds.Length; i++){// System.Globalization.NumberStyles.HexNumber); 轉成16進制數// 把ds[i]轉成16進制buffer[i] = byte.Parse(ds[i],System.Globalization.NumberStyles.HexNumber);}}else{// 不采用16進制的心跳包buffer = Encoding.UTF8.GetBytes(data);}foreach(var item in lists){item.GetStream().Write(buffer, 0, buffer.Length);}
}

關閉心跳

rivate void radioButton2_CheckedChanged(object sender, EventArgs e){timer1.Stop();}

重啟

private void button1_Click(object sender, EventArgs e)
{// 停掉tcpforeach (var item in lists){item.Close(); // 關閉所有的客戶端}listen.Stop();panel2.BackColor = Color.Gray;// 停掉窗口if (serialPort1.IsOpen) serialPort1.Close();// 滅燈this.panel1.BackColor = Color.Gray;// 開啟tcpstartTCP();// 開啟串口startChuanKou();
}

保存

private void button2_Click(object sender, EventArgs e)
{// "Serialport", "databit","8");Ini.Write("Serialport","name",comboBox1.Text);Ini.Write("Serialport", "botelv", comboBox2.Text);Ini.Write("Serialport", "stopbit", comboBox5.SelectedIndex);Ini.Write("Serialport", "parity", comboBox4.SelectedIndex);Ini.Write("Serialport", "databit", comboBox3.Text); // 5 6 7 8Ini.Write("NetWork", "port", textBox3.Text);Ini.Write("NetWork", "heartOn", radioButton1.Checked);Ini.Write("NetWork", "heartTime", textBox4.Text);Ini.Write("NetWork", "heartData", textBox5.Text);Ini.Write("NetWork", "heartHex", checkBox1.Checked);}

接受和發送默認值