Socket编程 (毗连,发送消息) (Tcp、Udp) - Part1

Socket编程 (毗连,发送消息) (Tcp、Udp)

---

本篇文章主要实现Socket在Tcp\Udp协议下相互通讯的方式。(服务器端与客户端的通讯)
1.基于Tcp协议的Socket通讯雷同于B/S架构，面向毗连，但差别的是服务器端可以向客户端主动推送消息。
利用Tcp协议通讯必要具备以下几个条件：
(1).创建一个套接字(Socket)
(2).绑定服务器端IP地址及端口号–服务器端
(3).利用Listen()方法开启监听–服务器端
(4).利用Accept()方法尝试与客户端创建一个毗连–服务器端
(5).利用Connect()方法与服务器创建毗连–客户端
(5).利用Send()方法向创建毗连的主机发送消息
(6).利用Recive()方法接受来自创建毗连的主机的消息(可靠毗连)

　2.基于Udp协议是无毗连模式通讯，占用资源少，相应速度快，延时低。至于可靠性，可通过应用层的控制来满足。(不可靠毗连)
(1).创建一个套接字(Socket)
(2).绑定服务器端IP地址及端口号–服务器端
(3).通过SendTo()方法向指定主机发送消息(需提供主机IP地址及端口)
(4).通过ReciveFrom()方法吸收指定主机发送的消息(需提供主机IP地址及端口)
　　　　

1、服务端

1. using System;
2. using System.Collections.Generic;
3. using System.Text;
4. #region 命名空间
5. using System.Net;
6. using System.Net.Sockets;
7. using System.Threading;
8. #endregion
10. namespace SocketServerConsole
11. {
12.     class Program
13.     {
14.         #region 控制台主函数
15.         /// <summary>
16.         /// 控制台主函数
17.         /// </summary>
18.         /// <param name="args"></param>
19.         static void Main(string[] args)
20.         {
21.             //主机IP
22.             IPEndPoint serverIP = new IPEndPoint(IPAddress.Parse("192.168.1.105"), 8686);
23.             Console.WriteLine("请选择连接方式：");
24.             Console.WriteLine("A.Tcp");
25.             Console.WriteLine("B.Udp");
26.             ConsoleKey key;
27.             while (true)
28.             {
29.                 key = Console.ReadKey(true).Key;
30.                 if (key == ConsoleKey.A) TcpServer(serverIP);
31.                 else if (key == ConsoleKey.B) UdpServer(serverIP);
32.                 else
33.                 {
34.                     Console.WriteLine("输入有误,请重新输入：");
35.                     continue;
36.                 }
37.                 break;
38.             }
39.         }
40.         #endregion
42.         #region Tcp连接方式
43.         /// <summary>
44.         /// Tcp连接方式
45.         /// </summary>
46.         /// <param name="serverIP"></param>
47.         public static void TcpServer(IPEndPoint serverIP)
48.         {
49.             Console.WriteLine("客户端Tcp连接模式");
50.             Socket tcpServer = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
51.             tcpServer.Bind(serverIP);
52.             tcpServer.Listen(100);
53.             Console.WriteLine("开启监听...");
54.             new Thread(() =>
55.             {
56.                 while (true)
57.                 {
58.                     try
59.                     {
60.                         TcpRecive(tcpServer.Accept());
61.                     }
62.                     catch (Exception ex)
63.                     {
64.                         Console.WriteLine(string.Format("出现异常：{0}", ex.Message));
65.                         break;
66.                     }
67.                 }
68.             }).Start();
69.             Console.WriteLine("\n\n输入"Q"键退出。");
70.             ConsoleKey key;
71.             do
72.             {
73.                 key = Console.ReadKey(true).Key;
74.             } while (key != ConsoleKey.Q);
75.             tcpServer.Close();
76.         }
78.         public static void TcpRecive(Socket tcpClient)
79.         {
80.             new Thread(() =>
81.             {
82.                 while (true)
83.                 {
84.                     byte[] data = new byte[1024];
85.                     try
86.                     {
87.                         int length = tcpClient.Receive(data);
88.                     }
89.                     catch (Exception ex)
90.                     {
91.                         Console.WriteLine(string.Format("出现异常：{0}", ex.Message));
92.                         break;
93.                     }
94.                     Console.WriteLine(string.Format("收到消息：{0}", Encoding.UTF8.GetString(data)));
95.                     string sendMsg = "收到消息！";
96.                     tcpClient.Send(Encoding.UTF8.GetBytes(sendMsg));
97.                 }
98.             }).Start();
99.         }
100.         #endregion
102.         #region Udp连接方式
103.         /// <summary>
104.         /// Udp连接方式
105.         /// </summary>
106.         /// <param name="serverIP"></param>
107.         public static void UdpServer(IPEndPoint serverIP)
108.         {
109.             Console.WriteLine("客户端Udp模式");
110.             Socket udpServer = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
111.             udpServer.Bind(serverIP);
112.             IPEndPoint ipep = new IPEndPoint(IPAddress.Any, 0);
113.             EndPoint Remote = (EndPoint)ipep;
114.             new Thread(() =>
115.             {
116.                 while (true)
117.                 {
118.                     byte[] data = new byte[1024];
119.                     try
120.                     {
121.                         int length = udpServer.ReceiveFrom(data, ref Remote);//接受来自服务器的数据
122.                     }
123.                     catch (Exception ex)
124.                     {
125.                         Console.WriteLine(string.Format("出现异常：{0}", ex.Message));
126.                         break;
127.                     }
128.                     Console.WriteLine(string.Format("{0} 收到消息：{1}", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), Encoding.UTF8.GetString(data)));
129.                     string sendMsg = "收到消息！";
130.                     udpServer.SendTo(Encoding.UTF8.GetBytes(sendMsg), SocketFlags.None, Remote);
131.                 }
132.             }).Start();
133.             Console.WriteLine("\n\n输入"Q"键退出。");
134.             ConsoleKey key;
135.             do
136.             {
137.                 key = Console.ReadKey(true).Key;
138.             } while (key != ConsoleKey.Q);
139.             udpServer.Close();
140.         }
141.         #endregion
142.     }
143. }

复制代码

2、客户端

1. using System;
2. using System.Collections.Generic;
3. using System.Text;
4. #region 命名空间
5. using System.Net.Sockets;
6. using System.Net;
7. using System.Threading;
8. #endregion
10. namespace SocketClientConsole
11. {
12.     class Program
13.     {
14.         #region 控制台主函数
15.         /// <summary>
16.         /// 控制台主函数
17.         /// </summary>
18.         /// <param name="args"></param>
19.         static void Main(string[] args)
20.         {
21.             //主机IP
22.             IPEndPoint serverIP = new IPEndPoint(IPAddress.Parse("192.168.1.77"), 8686);
23.             Console.WriteLine("请选择连接方式：");
24.             Console.WriteLine("A.Tcp");
25.             Console.WriteLine("B.Udp");
26.             ConsoleKey key;
27.             while (true)
28.             {
29.                 key = Console.ReadKey(true).Key;
30.                 if (key == ConsoleKey.A) TcpServer(serverIP);
31.                 else if (key == ConsoleKey.B) UdpClient(serverIP);
32.                 else
33.                 {
34.                     Console.WriteLine("输入有误,请重新输入：");
35.                     continue;
36.                 }
37.                 break;
38.             }
39.         }
40.         #endregion
42.         #region Tcp连接方式
43.         /// <summary>
44.         /// Tcp连接方式
45.         /// </summary>
46.         /// <param name="serverIP"></param>
47.         public static void TcpServer(IPEndPoint serverIP)
48.         {
49.             Console.WriteLine("客户端Tcp连接模式");
50.             Socket tcpClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
51.             try
52.             {
53.                 tcpClient.Connect(serverIP);
54.             }
55.             catch (SocketException e)
56.             {
57.                 Console.WriteLine(string.Format("连接出错：{0}", e.Message));
58.                 Console.WriteLine("点击任何键退出！");
59.                 Console.ReadKey();
60.                 return;
61.             }
62.             Console.WriteLine("客户端：client-->server");
63.             string message = "我上线了...";
64.             tcpClient.Send(Encoding.UTF8.GetBytes(message));
65.             Console.WriteLine(string.Format("发送消息：{0}", message));
66.             new Thread(() =>
67.             {
68.                 while (true)
69.                 {
70.                     byte[] data = new byte[1024];
71.                     try
72.                     {
73.                         int length = tcpClient.Receive(data);
74.                     }
75.                     catch (Exception ex)
76.                     {
77.                         Console.WriteLine(string.Format("出现异常：{0}", ex.Message));
78.                         break;
79.                     }
80.                     Console.WriteLine(string.Format("{0} 收到消息：{1}", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), Encoding.UTF8.GetString(data)));
81.                 }
82.             }).Start();
83.             Console.WriteLine("\n\n输入"Q"键退出。");
84.             ConsoleKey key;
85.             do
86.             {
87.                 key = Console.ReadKey(true).Key;
88.             } while (key != ConsoleKey.Q);
89.             tcpClient.Close();
90.         }
91.         #endregion
93.         #region Udp连接方式
94.         /// <summary>
95.         /// Udp连接方式
96.         /// </summary>
97.         /// <param name="serverIP"></param>
98.         public static void UdpClient(IPEndPoint serverIP)
99.         {
100.             Console.WriteLine("客户端Udp模式");
101.             Socket udpClient = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
102.             string message = "我上线了...";
103.             udpClient.SendTo(Encoding.UTF8.GetBytes(message), SocketFlags.None, serverIP);
104.             Console.WriteLine(string.Format("发送消息：{0}", message));
105.             IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0);
106.             EndPoint Remote = (EndPoint)sender;
107.             new Thread(() =>
108.             {
109.                 while (true)
110.                 {
111.                     byte[] data = new byte[1024];
112.                     try
113.                     {
114.                         int length = udpClient.ReceiveFrom(data, ref Remote);//接受来自服务器的数据
115.                     }
116.                     catch (Exception ex)
117.                     {
118.                         Console.WriteLine(string.Format("出现异常：{0}", ex.Message));
119.                         break;
120.                     }
121.                     Console.WriteLine(string.Format("{0} 收到消息：{1}", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), Encoding.UTF8.GetString(data)));
122.                 }
123.             }).Start();
124.             Console.WriteLine("\n\n输入"Q"键退出。");
125.             ConsoleKey key;
126.             do
127.             {
128.                 key = Console.ReadKey(true).Key;
129.             } while (key != ConsoleKey.Q);
130.             udpClient.Close();
131.         }
132.         #endregion
133.     }
134. }

复制代码

Tcp协议下通讯结果如下图：
客户端：
　　

服务器端：

基于Udp协议下通讯结果如下图：
客户端：

服务器端：

总结

Tcp协议相对通讯来说相对可靠，信息不易丢失,Tcp协议发送消息，发送失败时会重复发送消息等原因。所以对于要求通讯安全较高的程序来说，选择Tcp协议的通讯相对符合。Upd协议通讯个人是比力推荐的，占用资源小，低延时，相应速度快。至于可靠性是可以通过一些应用层加以封装控制得到相应的满足。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。