|
|
|
 |
當(dāng)前的位置 >> 返回首頁 >> 解決方案 |
 |
| 西安軟件C#中的串口，網(wǎng)口和PLC通訊 |
 |
| 發(fā)布者：西安軟件公司 發(fā)布時間：2022/8/18 閱讀：次 |
|
串口：串口是一個泛稱，UART、TTL、RS232、RS485都遵循類似的通信時序協(xié)議，因此都被通稱為串口
RS232：是電子工業(yè)協(xié)會(Electronic Industries Association，EIA) 制定的異步傳輸標(biāo)準(zhǔn)接口，同時對應(yīng)著電平標(biāo)準(zhǔn)和通信協(xié)議（時序），其電平標(biāo)準(zhǔn)：+3V～+15V對應(yīng)0，-3V～-15V對應(yīng)1。rs232 的邏輯電平和TTL 不一樣但是協(xié)議一樣
RS485：RS485是一種串口接口標(biāo)準(zhǔn)，為了長距離傳輸采用差分方式傳輸，傳輸?shù)氖遣罘中盘�，抗干擾能力比RS232強很多。兩線壓差為-(2~6)V表示0，兩線壓差為+(2~6)V表示1
TCP/IP 是互聯(lián)網(wǎng)相關(guān)的各類協(xié)議族的總稱，比如：TCP，UDP，IP，F(xiàn)TP，HTTP，ICMP，SMTP 等都屬于 TCP/IP 族內(nèi)的協(xié)議。像這樣把與互聯(lián)網(wǎng)相關(guān)聯(lián)的協(xié)議集合起來總稱為 TCP/IP。也有說法認(rèn)為，TCP/IP 是指 TCP 和 IP 這兩種協(xié)議。還有一種說法認(rèn)為，TCP/IP 是在 IP 協(xié)議的通信過程中，使用到的協(xié)議族的統(tǒng)稱。
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();
///多線程編程中，如果子線程需要使用主線程中創(chuàng)建的對象和控件，最好在主線程中體現(xiàn)進行檢查取消
///
CheckForIllegalCrossThreadCalls = false;
/// 獲取本地IP
textBox_current_address.Text = IPAddress.Any.ToString();
}
/// 創(chuàng)建一個字典，用來存儲記錄服務(wù)器與客戶端之間的連接(線程問題)
///
private Dictionary<string, Socket> clientList = new Dictionary<string, Socket>();
/// 創(chuàng)建連接
private void button_connect_Click(object sender, EventArgs e)
{
Thread myServer = new Thread(MySocket);
//設(shè)置這個線程是后臺線程
myServer.IsBackground = true;
myServer.Start();
}
//①:創(chuàng)建一個用于監(jiān)聽連接的Socket對象；
//②:用指定的端口號和服務(wù)器的Ip建立一個EndPoint對象；
//③:用Socket對象的Bind()方法綁定EndPoint；
//④:用Socket對象的Listen()方法開始監(jiān)聽；
//⑤:接收到客戶端的連接，用Socket對象的Accept()方法創(chuàng)建一個新的用于和客戶端進行通信的Socket對象；
//⑥:通信結(jié)束后一定記得關(guān)閉Socket。
/// 創(chuàng)建連接的方法
private void MySocket()
{
//1.創(chuàng)建一個用于監(jiān)聽連接的Socket對象；
Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP);
//2.用指定的端口號和服務(wù)器的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()方法開始監(jiān)聽；
//同一時刻內(nèi)允許同時加入鏈接的最大數(shù)量
server.Listen(20);
listBox_log.Items.Add("服務(wù)器已經(jīng)成功開啟!");
//5.接收到客戶端的連接，用Socket對象的Accept()方法創(chuàng)建一個新的用于和客戶端進行通信的Socket對象；
while (true)
{
//接受接入的一個客戶端
Socket connectClient = server.Accept();
if (connectClient != null)
{
string infor = connectClient.RemoteEndPoint.ToString();
clientList.Add(infor, connectClient);
listBox_log.Items.Add(infor + "加入服務(wù)器!");
///服務(wù)器將消息發(fā)送至客服端
string msg = infor + "已成功進入到聊天室!";
SendMsg(msg);
//每有一個客戶端接入時，需要有一個線程進行服務(wù)
Thread threadClient = new Thread(ReciveMsg);//帶參的方法可以把傳遞的參數(shù)放到start中
threadClient.IsBackground = true;
//創(chuàng)建的新的對應(yīng)的Socket和客戶端Socket進行通信
threadClient.Start(connectClient);
}
}
}
/// 服務(wù)器接收到客戶端發(fā)送的消息
private void ReciveMsg(object o)
{
//Socket connectClient = (Socket)o; //與下面效果一樣
Socket connectClient = o as Socket;//connectClient負(fù)責(zé)客戶端的通信
IPEndPoint endPoint = null;
while (true)
{
try
{
///定義服務(wù)器接收的字節(jié)大小
byte[] arrMsg = new byte[1024 * 1024];
///接收到的信息大小(所占字節(jié)數(shù))
int length = connectClient.Receive(arrMsg);
if (length > 0)
{
string recMsg = Encoding.UTF8.GetString(arrMsg, 0, length);
//獲取客戶端的端口號
endPoint = connectClient.RemoteEndPoint as IPEndPoint;
//服務(wù)器顯示客戶端的端口號和消息
listBox_log.Items.Add(DateTime.Now + "[" + endPoint.Port.ToString() + "]：" + recMsg);
//服務(wù)器(connectClient)發(fā)送接收到的客戶端信息給客戶端
SendMsg("[" + endPoint.Port.ToString() + "]：" + recMsg);
}
}
catch (Exception)
{
///移除添加在字典中的服務(wù)器和客戶端之間的線程
clientList.Remove(endPoint.ToString());
connectClient.Dispose();
}
}
}
/// 服務(wù)器發(fā)送消息，客戶端接收
private void SendMsg(string str)
{
///遍歷出字典中的所有線程
foreach (var item in clientList)
{
byte[] arrMsg = Encoding.UTF8.GetBytes(str);
///獲取鍵值(服務(wù)器），發(fā)送消息
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();
///多線程編程中，如果子線程需要使用主線程中創(chuàng)建的對象和控件，最好在主線程中體現(xiàn)進行檢查取消
CheckForIllegalCrossThreadCalls = false;
}
/// 創(chuàng)建客戶端
private Socket client;
private void button_connect_Click(object sender, EventArgs e)
{
///創(chuàng)建客戶端
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));
///建立與服務(wù)器的遠(yuǎn)程連接
try
{
client.Connect(endPoint);
}
catch(Exception)
{
MessageBox.Show("地址或端口錯誤�。。�！");
return;
}
///線程問題
Thread thread = new Thread(ReciveMsg);
thread.IsBackground = true;
thread.Start(client);
}
/// 客戶端接收到服務(wù)器發(fā)送的消息
private void ReciveMsg(object o)
{
Socket client = o as Socket;
while (true)
{
try
{
///定義客戶端接收到的信息大小
byte[] arrList = new byte[1024 * 1024];
///接收到的信息大小(所占字節(jié)數(shù))
int length = client.Receive(arrList);
string msg = DateTime.Now + Encoding.UTF8.GetString(arrList, 0, length);
listBox_log.Items.Add(msg);
}
catch (Exception)
{
///關(guān)閉客戶端
client.Close();
}
}
}
/// 客戶端發(fā)送消息給服務(wù)端
private void button_send_Click(object sender, EventArgs e)
{
if (textBox_message.Text != "")
{
SendMsg(textBox_message.Text);
}
}
/// 客戶端發(fā)送消息，服務(wù)端接收
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();
}
}
}
|
|
