udp套接字编程流程(udp 套接字)
UDP套接字编程（C++)求注释
这个需要一本书讲的，这里讲不清的。很多关于套接字的书unix程序猿建议看APUEwindows程序猿建议看《VC技术内幕》
关于c#中UDP编程
//这是一个源码你看看
using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Windows.Forms;
namespace UDPClient
{
public partial class frmUdp : Form
{
private UdpClient sendUdpClient;
private UdpClient receiveUpdClient;
public frmUdp()
{
InitializeComponent();
IPAddress[] ips = Dns.GetHostAddresses("");
tbxlocalip.Text = ips[3].ToString();
int port = 51883;
tbxlocalPort.Text = port.ToString();
tbxSendtoIp.Text = ips[3].ToString();
tbxSendtoport.Text = port.ToString();
}
// 接受消息
private void btnReceive_Click(object sender, EventArgs e)
{
// 创建接收套接字
IPAddress localIp = IPAddress.Parse(tbxlocalip.Text);
IPEndPoint localIpEndPoint = new IPEndPoint(localIp, int.Parse(tbxlocalPort.Text));
receiveUpdClient = new UdpClient(localIpEndPoint);
Thread receiveThread = new Thread(ReceiveMessage);
receiveThread.Start();
}
// 接收消息方法
private void ReceiveMessage()
{
IPEndPoint remoteIpEndPoint = new IPEndPoint(IPAddress.Any, 0);
while (true)
{
try
{
// 关闭receiveUdpClient时此时会产生异常
byte[] receiveBytes = receiveUpdClient.Receive(ref remoteIpEndPoint);
string message = Encoding.Unicode.GetString(receiveBytes);
// 显示消息内容
ShowMessageforView(lstbxMessageView, string.Format("{0}[{1}]", remoteIpEndPoint, message));
}
catch
{
break;
}
}
}
// 利用委托回调机制实现界面上消息内容显示
delegate void ShowMessageforViewCallBack(ListBox listbox, string text);
private void ShowMessageforView(ListBox listbox, string text)
{
if (listbox.InvokeRequired)
{
ShowMessageforViewCallBack showMessageforViewCallback = ShowMessageforView;
listbox.Invoke(showMessageforViewCallback, new object[] { listbox, text });
}
else
{
lstbxMessageView.Items.Add(text);
lstbxMessageView.SelectedIndex = lstbxMessageView.Items.Count - 1;
lstbxMessageView.ClearSelected();
}
}
private void btnSend_Click(object sender, EventArgs e)
{
if (tbxMessageSend.Text == string.Empty)
{
MessageBox.Show("发送内容不能为空","提示");
return;
}
// 选择发送模式
if (chkbxAnonymous.Checked == true)
{
// 匿名模式(套接字绑定的端口由系统随机分配)
sendUdpClient = new UdpClient(0);
}
else
{
// 实名模式(套接字绑定到本地指定的端口)
IPAddress localIp = IPAddress.Parse(tbxlocalip.Text);
IPEndPoint localIpEndPoint = new IPEndPoint(localIp, int.Parse(tbxlocalPort.Text));
sendUdpClient = new UdpClient(localIpEndPoint);
}
Thread sendThread = new Thread(SendMessage);
sendThread.Start(tbxMessageSend.Text);
}
// 发送消息方法
private void SendMessage(object obj)
{
string message = (string)obj;
byte[] sendbytes = Encoding.Unicode.GetBytes(message);
IPAddress remoteIp = IPAddress.Parse(tbxSendtoIp.Text);
IPEndPoint remoteIpEndPoint = new IPEndPoint(remoteIp, int.Parse(tbxSendtoport.Text));
sendUdpClient.Send(sendbytes, sendbytes.Length, remoteIpEndPoint);
sendUdpClient.Close();
// 清空发送消息框
ResetMessageText(tbxMessageSend);
}
// 采用了回调机制
// 使用委托实现跨线程界面的操作方式
delegate void ResetMessageCallback(TextBox textbox);
private void ResetMessageText(TextBox textbox)
{
// Control.InvokeRequired属性代表
// 如果控件的处理与调用线程在不同线程上创建的，则为true,否则为false
if (textbox.InvokeRequired)
{
ResetMessageCallback resetMessagecallback = ResetMessageText;
textbox.Invoke(resetMessagecallback, new object[] { textbox });
}
else
{
textbox.Clear();
textbox.Focus();
}
}
// 停止接收
private void btnStop_Click(object sender, EventArgs e)
{
receiveUpdClient.Close();
}
// 清空接受消息框
private void btnClear_Click(object sender, EventArgs e)
{
this.lstbxMessageView.Items.Clear();
}
}
}
在javasocket网络编程中,开发基于udp协议的程序使用的套接字有哪些
Socket套接字，是由系统提供用于网络通信的技术（操作系统给应用程序提供的一组API叫做Socket API），是基于TCP/IP协议的网络通信的基本操作单元。基于Socket套接字的网络程序开发就是网络编程。
socket可以视为是应用层和传输层之间的通信桥梁；
传输层的核心协议有两种：TCP,UDP；socket API也有对应的两组，由于TCP和UDP协议差别很大,因此,这两组API差别也挺大。
分类：
Socket套接字主要针对传输层协议划分为如下三类：
流套接字：使用传输层TCP协议
TCP，即Transmission Control Protocol（传输控制协议），传输层协议；
TCP的特点：
有连接：像打电话,得先接通,才能交互数据；
可靠传输：传输过程中,发送方知道接收方有没有收到数据.（打电话就是可靠传输）；
面向字节流：以字节为单位进行传输.(非常类似于文件操作中的字节流)；
全双工：一条链路,双向通信；
有接收缓冲区，也有发送缓冲区。
大小不限
对于字节流来说，可以简单的理解为，传输数据是基于IO流，流式数据的特征就是在IO流没有关闭的情况下，是无边界的数据，可以多次发送，也可以分开多次接收。
数据报套接字：使用传输层UDP协议
UDP，即User Datagram Protocol（用户数据报协议），传输层协议。
UDP的特点：
无连接：像发微信,不需要接通,直接就能发数据；
不可靠传输：传输过程中,发送方不知道接收方有没有收到数据.（发微信就是不可靠传输）；
面向数据报：以数据报为单位进行传输(一个数据报都会明确大小)一次发送/接收必须是一个完整的数据报,不能是半个,也不能是一个半；
全双工：一条链路，双向通信；
有接收缓冲区，无发送缓冲区；
大小受限：一次最多传输64k；
对于数据报来说，可以简单的理解为，传输数据是一块一块的，发送一块数据假如100个字节，必须一次发送，接收也必须一次接收100个字节，而不能分100次，每次接收1个字节。
原始套接字
原始套接字用于自定义传输层协议，用于读写内核没有处理的IP协议数据。
二、UDP数据报套接字编程
UDPSocket中，主要涉及到两类：DatagramSocket、DatagramPacket;
DatagramSocket API
DatagramSocket 创建了一个UDP版本的Socket对象，用于发送和接收UDP数据报，代表着操作系统中的一个socket文件，（操作系统实现的功能–）代表着网卡硬件设备的抽象体现。
DatagramSocket 构造方法:
方法签名 方法说明
DatagramSocket() 创建一个UDP数据报套接字的Socket，绑定到本机任意一个随机端口（一般用于客户端）
DatagramSocket(int port) 创建一个UDP数据报套接字的Socket，绑定到本机指定的端口（一般用于服务端）
DatagramSocket 方法：
方法签名 方法说明
void receive(DatagramPacket p) 从此套接字接收数据报（如果没有接收到数据报，该方法会阻塞等待）
void send(DatagramPacket p) 从此套接字发送数据报包（不会阻塞等待，直接发送）
void close() 关闭此数据报套接字
DatagramPacket API
代表了一个UDP数据报，是UDP Socket发送和接收的数据报，每次发送/接收数据报，都是在传输一个DatagramPacket对象。
DatagramPacket 构造方法：
方法签名 方法说明
DatagramPacket(byte[] buf, int length) 构造一个DatagramPacket以用来接收数据报，接收的数据保存在字节数组(第一个参数buf)中，接收指定长度(第二个参数length)
DatagramPacket(byte[] buf, int offset, int length,SocketAddress address) 构造一个DatagramPacket以用来发送数据报，发送的数据为字节数组(第一个参数buf)中，从0到指定长度(第二个参数length)。address指定目的主机的IP和端口号
DatagramPacket 方法：
方法签名 方法说明
InetAddress getAddress() 从接收的数据报中，获取发送端主机IP地址；或从发送的数据报中，获取接收端主机IP地址
int getPort() 从接收的数据报中，获取发送端主机的端口号；或从发送的数据报中，获取接收端主机端口号
byte[] getData() 获取数据报中的数据
构造UDP发送的数据报时，需要传入 SocketAddress ，该对象可以使用 InetSocketAddress 来创建。
InetSocketAddress API
InetSocketAddress （ SocketAddress 的子类 ）构造方法：
方法签名 方法说明
InetSocketAddress(InetAddress addr, int port) 创建一个Socket地址，包含IP地址和端口号
示例1：写一个简单的客户端服务程序，回显服务（EchoSever）
在这里插入图片描述
构建Socket对象有很多失败的可能：
端口号已经被占用，同一个主机的两个程序不能有相同的端口号（这就好比两个人不能拥有相同的电话号码）；
此处，多个进程不能绑定同一个端口号，但是一个进程可以绑定多个端口，（这就好比一个人可以拥有多个手机号），一个进程可以创建多个Socket对象，每个Socket都绑定自己的端口。
每个进程能够打开的文件个数是有上限的，如果进程之间已经打开了很多文件，就可能导致此时的Socket文件不能顺利打开；
在这里插入图片描述
这个长度不一定是1024，假设这里的UDP数据最长是1024，实际的数据可能不够1024.
在这里插入图片描述
这里的参数不再是一个空的字节数组了，response是刚才根据请求计算的得到的响应，是非空的，DatagramPacket 里面的数据就是String response的数据。
response.getBytes().length：这里拿到的是字节数组的长度（字节的个数），而response.length得到的是字符的长度。
五元组
一次通信是由5个核心信息描述的：源IP、 源端口、 目的IP、 目的端口、 协议类型。
站在客户端角度：
源IP:本机IP；
源端口：系统分配的端口；
目的IP：服务器的IP；
目的端口：服务器的端口；
协议类型：TCP；
站在服务器的角度：
源IP:服务器程序本机的IP；
源端口：服务器绑定的端口（此处手动指定了9090）；
目的IP：包含在收到的数据报中（客户端的IP）；
目的端口：包含在收到的数据报中（客户端的端口）；
协议类型：UDP；
UDP连接方式详解
服务器端（接收端）程序：
1、创建套接字（socket）。
2、将套接字绑定到一个本地地址和端口上（bind）。
3、等待接收数据（recvfrom）。
4、关闭套接字。
客户端（发送端）程序：
1、创建套接字（socket）。
2、向服务器发送数据（sendto）。
3、关闭套接字。
client.c#include Winsock2.h#include stdio.hvoid main(){ WORD wVersionRequested; WSADATA wsaData; int err; wVersionRequested = MAKEWORD( 1, 1 ); err = WSAStartup( wVersionRequested, wsaData ); if ( err != 0 ) { return; } if ( LOBYTE( wsaData.wVersion ) != 1 || HIBYTE( wsaData.wVersion ) != 1 ) { WSACleanup( ); return; } SOCKET sockClient=socket(AF_INET,SOCK_DGRAM,0); SOCKADDR_IN addrSrv; addrSrv.sin_addr.S_un.S_addr=inet_addr("222.26.28.227"); addrSrv.sin_family=AF_INET; addrSrv.sin_port=htons(5001); sendto(sockClient,"Hello",strlen("Hello")+1,0, (SOCKADDR*)addrSrv,sizeof(SOCKADDR));// printf("%d\n", sendto(sockClient,"Hello",strlen("Hello")+1,0,// (SOCKADDR*)addrSrv,sizeof(SOCKADDR))); closesocket(sockClient); WSACleanup();}server.c#include Winsock2.h#include stdio.hvoid main(){ WORD wVersionRequested; WSADATA wsaData; int err; wVersionRequested = MAKEWORD( 1, 1 ); err = WSAStartup( wVersionRequested, wsaData ); if ( err != 0 ) { return; } if ( LOBYTE( wsaData.wVersion ) != 1 || HIBYTE( wsaData.wVersion ) != 1 ) { WSACleanup( ); return; } SOCKET sockSrv=socket(AF_INET,SOCK_DGRAM,0); SOCKADDR_IN addrSrv; addrSrv.sin_addr.S_un.S_addr=htonl(INADDR_ANY); addrSrv.sin_family=AF_INET; addrSrv.sin_port=htons(5001); bind(sockSrv,(SOCKADDR*)addrSrv,sizeof(SOCKADDR)); SOCKADDR_IN addrClient; int len = sizeof(SOCKADDR);// int len=sizeof(addrClient); char recvBuf[100] = "\0"; printf("Wating for message from others: \n"); int a = recvfrom(sockSrv,recvBuf,100,0, (SOCKADDR*)addrClient,len); if(a == SOCKET_ERROR) { printf("Error\n"); printf("%s\n", WSAGetLastError()); } printf("%s\n",recvBuf); closesocket(sockSrv); WSACleanup();}
Socket 通信之 UDP 通信
前段时间，我们在 这篇文章 中谈到了多进程和进程之间的通信方式，主要谈到了本地进程之间使用队列（Queue）进程通信，如果我们要通信的进程不在同一台主机上，我们就无法使用队列进行通信了，这时就需要使用 Socket（套接字）。
Socket 是应用层和传输层之间的一层抽象协议，可以用来进行进程间通信，一般有 UDP 和 TCP 两种通信方式，前者速度稍快，稳定性不好，无法丢包重传。后者速度稍慢一点，但稳定性很好，可以丢包重传。
本文首先介绍使用 Socket 进行 UDP 通信。
使用 Socket 进行 UDP 通信的流程如下：
下面依次进行讲解。
要进行 Socket 通信，我们需要使用 socket 模块，首先需要创建一个 Socket 对象。下面是两种创建方式：
如果我们需要向别的主机发送数据，我们需要改主机的 IP 地址和相应的端口号。在使用 Socket 进行通信时，需要将两个信息写在一元组中，元组的第一项为目标主机 IP 地址，第二项为接受数据的端口号：
其中，IP 地址使用字符串类型，端口号使用数字类型。
如果不绑定端口，每次使用 Socket 时都会由操作系统动态分配一个端口，我们也可以绑定为某个固定的端口。这样做的好处是：如果我们想要接受其他主机的信息，其他主机可以直接向这个端口发送数据，如果使用动态端口的话，发送方并不知道目标端口是什么，因此无法向接收方发送数据。
绑定端口需要使用 Socket 对象的 bind 方法：
bind 方法接受一个元组作为参数，元组的第一项为绑定的 IP 地址，第二项为绑定的端口号。我们可以把第一项指定为本机上的任意一个 IP 地址，也可以设置为一个空字符串 "" ，表示本机上任意合法的 IP 地址。
使用 UDP 套接字协议时，发送数据使用 Socket 对象的 sendto 方法，接受数据使用 Socket 对象的 recvfrom 方法。这两个方法的使用方式如下：
sendto 方法接受两个参数：发送的数据和目标主机的 IP 和端口元组，在 Python3 中，发送的数据应该转为 byte 类型发送，Python2 中可以直接发送字符串。
recvfrom 接受一个参数：本次接受的最大数据尺寸。该方法是阻塞的，只有在接收到数据后才能进行后续的操作。
就像使用文件那样，在使用完套接字后，需要关闭它，调用 close 方法即可。
上面我们介绍了 Socket 的使用方式，下面我们来做一个单工通信的例子（一方负责发送信息，一方负责接收信息）。
我们这里来创建两个文件：用以发送信息的 send.py 和用以接收信息的 recv.py。该实例在虚拟机中模拟（注意将虚拟机设置为桥接模式）。
创建 send.py：
创建 recv.py：
运行结果如下：
上面实现了一个单工通信的例子：一方负责发，一方负责接收。下面我们继续实现一个双工通信的例子，使双方都能够收发消息。
由于接收和发送消息时是使用 while 循环不断轮询的，因此要实现同时发送和接受，我们需要进行多任务处理。
新建一个 msg.py：
这里我们使用 3000 端口发送数据，3001 端口接收数据，运行程序时只需填写目标主机的 IP 地址，就可以进行通信。
运行效果：
我们还可以进行局域网内的广播，只需对 Socket 加上一条设置：
同时，发送广播需要一个广播地址，以及目标主机接受广播的端口：
上面的设置只能给 0 网段的主机发送广播，要想给局域网中所有的主机发送广播，可以这样设置：
下面我们新建一个 send.py 用来发送广播：
新建一个 recv.py 用来接收广播：
运行效果如图：
完。