博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
C# 通过socket实现UDP 通信
阅读量:5065 次
发布时间:2019-06-12

本文共 3491 字,大约阅读时间需要 11 分钟。

 UDP不属于面向连接的通信,在选择使用协议的时候,选择UDP必须要谨慎。在网络质量令人十分不满意的环境下,UDP协议数据包丢失会比较严重。但是由于UDP的特性:它不属于连接型协议,因而具有资源消耗小,处理速度快的优点,所以通常音频、视频和普通数据在传送时使用UDP较多,因为它们即使偶尔丢失一两个数据包,也不会对接收结果产生太大影响。比如我们聊天用的ICQ和QQ就是使用的UDP协议。

我们通过UDP进行信息收发的时候,没有严格客户端和服务端的区别,它不同于UDP,UDP 必须建立可靠连接之后才可以通信,而UDP随时都可以给指定的ip和端口所对应进程发送消息。UDP发送消息时需要绑定自己IP 和 端口号,接收消息的时候没有特殊限制,只要有人给自己发送,自己在线,就可以接收。

 

服务端程序:

using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;using System.Net.Sockets;using System.Net;using System.Threading;namespace UDP_Server{    class Program    {        static Socket server;        static void Main(string[] args)        {            server = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);            server.Bind(new IPEndPoint(IPAddress.Parse("169.254.202.67"), 6001));//绑定端口号和IP            Console.WriteLine("服务端已经开启");            Thread t = new Thread(ReciveMsg);//开启接收消息线程            t.Start();            Thread t2 = new Thread(sendMsg);//开启发送消息线程            t2.Start();        }        ///         /// 向特定ip的主机的端口发送数据报        ///         static void sendMsg()        {            EndPoint point = new IPEndPoint(IPAddress.Parse("169.254.202.67"), 6000);            while (true)            {                string msg = Console.ReadLine();                server.SendTo(Encoding.UTF8.GetBytes(msg), point);            }        }        ///         /// 接收发送给本机ip对应端口号的数据报        ///         static void ReciveMsg()        {            while (true)            {                EndPoint point = new IPEndPoint(IPAddress.Any, 0);//用来保存发送方的ip和端口号                byte[] buffer = new byte[1024];                int length = server.ReceiveFrom(buffer, ref point);//接收数据报                string message = Encoding.UTF8.GetString(buffer,0,length);                Console.WriteLine(point.ToString()+ message);            }        }    }}

客户端程序

using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;using System.Net;using System.Net.Sockets;using System.Threading;namespace UDP_client{    class Program    {        static Socket client;        static void Main(string[] args)        {            client = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);            client.Bind(new IPEndPoint(IPAddress.Parse("169.254.202.67"), 6000));            Thread t = new Thread(sendMsg);            t.Start();            Thread t2 = new Thread(ReciveMsg);            t2.Start();            Console.WriteLine("客户端已经开启");        }        ///         /// 向特定ip的主机的端口发送数据报        ///         static void sendMsg()        {            EndPoint point = new IPEndPoint(IPAddress.Parse("169.254.202.67"), 6001);            while(true){                string msg = Console.ReadLine();                client.SendTo(Encoding.UTF8.GetBytes(msg), point);            }        }        ///         /// 接收发送给本机ip对应端口号的数据报        ///         static void ReciveMsg()        {            while (true)            {                EndPoint point = new IPEndPoint(IPAddress.Any, 0);//用来保存发送方的ip和端口号                byte[] buffer = new byte[1024];                int length = client.ReceiveFrom(buffer, ref point);//接收数据报                string message = Encoding.UTF8.GetString(buffer, 0, length);                Console.WriteLine(point.ToString() + message);            }        }    }}

 

来源:http://blog.csdn.net/u011484013/article/details/51131267

转载于:https://www.cnblogs.com/dj1232090/p/7608215.html

你可能感兴趣的文章
Eclipse 调试的时候Tomcat报错启动不了
查看>>
ES6内置方法find 和 filter的区别在哪
查看>>
Android实现 ScrollView + ListView无滚动条滚动
查看>>
java学习笔记之String类
查看>>
UVA 11082 Matrix Decompressing 矩阵解压(最大流,经典)
查看>>
jdk从1.8降到jdk1.7失败
查看>>
硬件笔记之Thinkpad T470P更换2K屏幕
查看>>
iOS开发——缩放图片
查看>>
HTTP之URL的快捷方式
查看>>
满世界都是图论
查看>>
配置链路聚合中极小错误——失之毫厘谬以千里
查看>>
代码整洁
查看>>
蓝桥杯-分小组-java
查看>>
Android Toast
查看>>
iOS开发UI篇—Quartz2D使用(绘制基本图形)
查看>>
docker固定IP地址重启不变
查看>>
桌面图标修复||桌面图标不正常
查看>>
JavaScript基础(四)关于对象及JSON
查看>>
JAVA面试常见问题之Redis篇
查看>>
jdk1.8 api 下载
查看>>