【Linux】socket网络编程之UDP
个人主页~
socket网络编程UDP
- 一、必备接口
- 1、接收数据
- 2、发送数据
- 二、实现UDP网络编程
- 1、服务器
- （一）UdpServer.hpp
- （二）main.cpp
- 2、客户端
- UdpClient.cpp
一、必备接口
1、接收数据
recvfrom函数用于从套接字接收数据
#include 返回值：返回正数表示成功接收到的数据字节数，返回0表示对方已经关闭了连接（对于TCP），返回-1表示发生错误
sockfd：指定从哪个套接字接收数据
buf：指向一个缓冲区，用于存储接收到的数据
len：指定buf的最大长度
flags：设置接收数据的标志，无标志一般设为0，在这里可以设置非阻塞模式
src_addr：用于存储发送方的地址信息，输出型参数
addrlen：用于指定src_addr结构体的长度，输入输出型参数，在调用 recvfrom 函数之前，需要将其初始化为 src_addr 结构体的最大长度,函数返回时，addrlen 会被更新为实际存储在 src_addr 中的地址信息的长度
2、发送数据
sendto函数用于在无连接的套接字（如 UDP 套接字）上发送数据
#include 返回值：返回正数表示成功发送的数据字节数，返回-1表示发送过程中出现错误
sockfd：指定通过哪个套接字发送数据
buf：指向要发送的数据的缓冲区
len：表示要发送的数据的长度（以字节为单位），即 buf 缓冲区中实际要发送的数据的字节数
flags：设置发送数据的标志，无标志一般设为0，在这里可以设置非阻塞模式
dest_addr:该结构体包含了目标地址的信息
addrlen：表示dest_addr结构体的长度（以字节为单位）
二、实现UDP网络编程
1、服务器
（一）UdpServer.hpp
#pragma once
#include ;
typedef std::function<std::string(const std::string&)> func_t;
//枚举错误类型
enum{
SOCKET_ERR=1,
BIND_ERR
};
//定义端口号和ip地址
uint16_t defaultport = 8080;
std::string defaultip = "0.0.0.0";
//size用来定义缓冲区大小
const int size = 1024;
class UdpServer{
public:
UdpServer(const uint16_t &port = defaultport, const std::string &ip = defaultip)
:sockfd_(0), port_(port), ip_(ip),isrunning_(false)
{}
void Init()
{
// 创建udp socket
sockfd_ = socket(AF_INET, SOCK_DGRAM, 0);
if(sockfd_ < 0)
{
exit(SOCKET_ERR);
}
// 定义一个local存储本地地址
struct sockaddr_in local;
//bzero的作用就是将local结构体清零
bzero(&local, sizeof(local));
//将local的前两个字节也就是它的地址族为AF_INET
local.sin_family = AF_INET;
//保证我们的端口号是网络字节序列，因为该端口号是要给对方发送的
local.sin_port = htons(port_);
//inet_addr函数将ip_转换为in_addr_t类型的IP地址，并存储在local.sin_addr.s_addr
local.sin_addr.s_addr = inet_addr(ip_.c_str());
//绑定sockfd_到本地地址local上，失败则退出
if(bind(sockfd_, (const struct sockaddr *)&local, sizeof(local)) < 0)
{
exit(BIND_ERR);
}
}
void Run(func_t func) // 对代码进行分层
{
//设置服务器开始运行标志
isrunning_ = true;
//定义缓冲区存放接收到的数据
char inbuffer[size];
while(isrunning_)
{
//定义client结构体存储客户端的地址信息
struct sockaddr_in client;
socklen_t len = sizeof(client);
//获取客户端信息
ssize_t n = recvfrom(sockfd_, inbuffer, sizeof(inbuffer) - 1, 0,
(struct sockaddr*)&client, &len);
if(n < 0)
{
continue;
}
//在最后添加字符串描述符' '
inbuffer[n] = 0;
//将所有的信息通过func函数处理为echo_string
std::string info = inbuffer;
std::string echo_string = func(info);
//将处理完后的数据发送到客户端
sendto(sockfd_, echo_string.c_str(), echo_string.size(), 0,
(const sockaddr*)&client, len);
}
}
//析构，sockfd_本质上是一个文件描述符一样的东西，用close可以关闭
~UdpServer()
{
if(sockfd_>0) close(sockfd_);
}
private:
int sockfd_; // 网路文件描述符
std::string ip_; // 任意地址bind 0
uint16_t port_; // 表明服务器进程的端口号
bool isrunning_; // 服务器运行状态
};
（二）main.cpp
#include "UdpServer.hpp"
#include 2、客户端
UdpClient.cpp
#include 最终我们实现的就是一个客户端可以通过指令操控服务器，然后将服务器应该输出的结果打印到客户端
今日分享就到这里了~
