串口:串口是一個泛稱,UART、TTL、RS232、RS485都遵循類似的通信時序協議,因此都被通稱為串口 RS232:是電子工業協會(Electronic Industries Association,EIA) 制定的異步傳輸標準接口,同時對應著電平標準和通信協議(時序),其電平標準:+3V~+15V對應0,-3V~-15V對應1。rs232 的邏輯電平和TTL 不一樣但是協議一樣 RS485:RS485是一種串口接口標準,為了長距離傳輸采用差分方式傳輸,傳輸的是差分信號,抗干擾能力比RS232強很多。兩線壓差為-(2~6)V表示0,兩線壓差為+(2~6)V表示1 TCP/IP 是互聯網相關的各類協議族的總稱,比如:TCP,UDP,IP,FTP,HTTP,ICMP,SMTP 等都屬于 TCP/IP 族內的協議。像這樣把與互聯網相關聯的協議集合起來總稱為 TCP/IP。也有說法認為,TCP/IP 是指 TCP 和 IP 這兩種協議。還有一種說法認為,TCP/IP 是在 IP 協議的通信過程中,使用到的協議族的統稱。
c# tcp/ip通信
using System; using System.Collections.Generic; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; using System.Windows.Forms; namespace csharpService { public partial class Service : Form { public Service() { InitializeComponent(); ///多線程編程中,如果子線程需要使用主線程中創建的對象和控件,最好在主線程中體現進行檢查取消 /// CheckForIllegalCrossThreadCalls = false; /// 獲取本地IP textBox_current_address.Text = IPAddress.Any.ToString(); } /// 創建一個字典,用來存儲記錄服務器與客戶端之間的連接(線程問題) /// private Dictionary<string, Socket> clientList = new Dictionary<string, Socket>(); /// 創建連接 private void button_connect_Click(object sender, EventArgs e) { Thread myServer = new Thread(MySocket); //設置這個線程是后臺線程 myServer.IsBackground = true; myServer.Start(); } //①:創建一個用于監聽連接的Socket對象; //②:用指定的端口號和服務器的Ip建立一個EndPoint對象; //③:用Socket對象的Bind()方法綁定EndPoint; //④:用Socket對象的Listen()方法開始監聽; //⑤:接收到客戶端的連接,用Socket對象的Accept()方法創建一個新的用于和客戶端進行通信的Socket對象; //⑥:通信結束后一定記得關閉Socket。 /// 創建連接的方法 private void MySocket() { //1.創建一個用于監聽連接的Socket對象; Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP); //2.用指定的端口號和服務器的Ip建立一個EndPoint對象; IPAddress iP = IPAddress.Parse(textBox_current_address.Text); IPEndPoint endPoint = new IPEndPoint(iP, int.Parse(textBox_port.Text)); //3.用Socket對象的Bind()方法綁定EndPoint; server.Bind(endPoint); //4.用Socket對象的Listen()方法開始監聽; //同一時刻內允許同時加入鏈接的最大數量 server.Listen(20); listBox_log.Items.Add("服務器已經成功開啟!"); //5.接收到客戶端的連接,用Socket對象的Accept()方法創建一個新的用于和客戶端進行通信的Socket對象; while (true) { //接受接入的一個客戶端 Socket connectClient = server.Accept(); if (connectClient != null) { string infor = connectClient.RemoteEndPoint.ToString(); clientList.Add(infor, connectClient); listBox_log.Items.Add(infor + "加入服務器!"); ///服務器將消息發送至客服端 string msg = infor + "已成功進入到聊天室!"; SendMsg(msg); //每有一個客戶端接入時,需要有一個線程進行服務 Thread threadClient = new Thread(ReciveMsg);//帶參的方法可以把傳遞的參數放到start中 threadClient.IsBackground = true; //創建的新的對應的Socket和客戶端Socket進行通信 threadClient.Start(connectClient); } } } /// 服務器接收到客戶端發送的消息 private void ReciveMsg(object o) { //Socket connectClient = (Socket)o; //與下面效果一樣 Socket connectClient = o as Socket;//connectClient負責客戶端的通信 IPEndPoint endPoint = null; while (true) { try { ///定義服務器接收的字節大小 byte[] arrMsg = new byte[1024 * 1024]; ///接收到的信息大小(所占字節數) int length = connectClient.Receive(arrMsg);
if (length > 0) { string recMsg = Encoding.UTF8.GetString(arrMsg, 0, length); //獲取客戶端的端口號 endPoint = connectClient.RemoteEndPoint as IPEndPoint; //服務器顯示客戶端的端口號和消息 listBox_log.Items.Add(DateTime.Now + "[" + endPoint.Port.ToString() + "]:" + recMsg); //服務器(connectClient)發送接收到的客戶端信息給客戶端 SendMsg("[" + endPoint.Port.ToString() + "]:" + recMsg); } } catch (Exception) { ///移除添加在字典中的服務器和客戶端之間的線程 clientList.Remove(endPoint.ToString()); connectClient.Dispose();
} } } /// 服務器發送消息,客戶端接收 private void SendMsg(string str) { ///遍歷出字典中的所有線程 foreach (var item in clientList) { byte[] arrMsg = Encoding.UTF8.GetBytes(str); ///獲取鍵值(服務器),發送消息 item.Value.Send(arrMsg); } } } } using System; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; using System.Windows.Forms; namespace csharp_Client { public partial class Client : Form { public Client() { InitializeComponent(); ///多線程編程中,如果子線程需要使用主線程中創建的對象和控件,最好在主線程中體現進行檢查取消 CheckForIllegalCrossThreadCalls = false; } /// 創建客戶端 private Socket client; private void button_connect_Click(object sender, EventArgs e) { ///創建客戶端 client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP); ///IP地址 IPAddress ip = IPAddress.Parse(textBox_address.Text); ///端口號 IPEndPoint endPoint = new IPEndPoint(ip, int.Parse(textBox_port.Text)); ///建立與服務器的遠程連接 try { client.Connect(endPoint); } catch(Exception) { MessageBox.Show("地址或端口錯誤�。。�!"); return; } ///線程問題 Thread thread = new Thread(ReciveMsg); thread.IsBackground = true; thread.Start(client); } /// 客戶端接收到服務器發送的消息 private void ReciveMsg(object o) { Socket client = o as Socket; while (true) { try { ///定義客戶端接收到的信息大小 byte[] arrList = new byte[1024 * 1024]; ///接收到的信息大小(所占字節數) int length = client.Receive(arrList); string msg = DateTime.Now + Encoding.UTF8.GetString(arrList, 0, length); listBox_log.Items.Add(msg); } catch (Exception) { ///關閉客戶端 client.Close(); } } } /// 客戶端發送消息給服務端 private void button_send_Click(object sender, EventArgs e) { if (textBox_message.Text != "") { SendMsg(textBox_message.Text); } } /// 客戶端發送消息,服務端接收 private void SendMsg(string str) { byte[] arrMsg = Encoding.UTF8.GetBytes(str); client.Send(arrMsg); }
private void Client_FormClosed(object sender, FormClosedEventArgs e) { if(client!=null) client.Close(); } } } |
|