用网站免费模板做网站要会什么,建设银行网站登录密码,四川平台网站建设方案,企业网站及信息化建设Socket 是网络协议栈暴露给编程人员的 API#xff0c;相比复杂的计算机网络协议#xff0c;API 对关键操作和配置数据进行了抽象#xff0c;简化了程序编程。 本文讲述的 socket 内容源自 Linux man。本文主要对各 API 进行详细介绍#xff0c;从而更好的理解 socket 编程。… Socket 是网络协议栈暴露给编程人员的 API相比复杂的计算机网络协议API 对关键操作和配置数据进行了抽象简化了程序编程。 本文讲述的 socket 内容源自 Linux man。本文主要对各 API 进行详细介绍从而更好的理解 socket 编程。 send send() 遵循 POSIX.1 - 2008 MSG_CONFIRM 是 Linux 扩展 1.库 标准 c 库libc, -lc 2.头文件 sys/socket.h 3.接口定义 ssize_t send(int sockfd, const void buf[.len], size_t len, int flags);ssize_t sendto(int sockfd, const void buf[.len], size_t len, int flags,const struct sockaddr *dest_addr, socklen_t addrlen);ssize_t sendmsg(int sockfd, const struct msghdr *msg, int flags); 4.接口描述 send()、sendto()、sendmsg() 调用用来向另一个套接字发送消息。 send() 通常只能用在连接状态即接收者已知的套接字上send() 和 write(2) 的唯一不同是 send() 存在 flags 标记。当标记为 0 时send() 和 write(2) 等效。同样的下面的两个调用也是等效的。 send(sockfd, buf, len, flags);sendto(sockfd, buf, len, flags, NULL, 0);sockfd 参数是 发送套接字的文件描述符。 如果sendto() 用在连接模式SOCK_STREAM、SOCK_SEQPACKET的套接字上那么参数 dest_addr 和 addrlen 将被忽略当它们不是 NULL 或者 0时会返回 EISCON 错误并且当套接字没有连接时会返回 ENOTCONN 错误。否则需要给定 addrlen 指定长度的 dest_addr 目标地址目标地址由 msg.msg_name 给定长度是 msg.msg_namelen 指定。 对于 send() 和 sendto()发送的消息放在 len 长度的 buf 中。对于 sendmsg()消息由 msg.msg_iov 数组元素指定sendmsg() 调用同时允许发送一些辅助数据也称为控制信息。 如果消息太大以至于不能自动的透传给底层协议调用会返回 EMSGSIZE 错误该消息不会被发送。 send() 调用没有显示的关于传输失败的指示在内部检测到这类错误时也只会返回 -1。 当消息不能装进套接字的发送缓冲区时send() 正常会阻塞除非套接字放进了非阻塞 I/O 模式这种情况在非阻塞模式下会报告 EAGAIN 或者 EWOULDBLOCK 错误。这时可以使用 select(2) 来检测什么时候可以发送更多数据。
flags 参数 flags 参数可以是下面值的位或 MSG_CONFIRMLinux 2.3.15 后 告诉链路层有进展发生从对端收到了一个成功的回复。如果链路层没有收到这个那么它通常会在骚扰邻居通过 ARP 单播。这个标记只在IPv4/IPv6 的 SOCK_DGRAM 和 SOCK_RAW 套接字中可用详细信息可以参考 arp(7)。 MSG_DONTROUTE 不要使用向网关发送我们的数据包只发给和我们直接连接的主机。这个通常只有诊断或者路由程序使用。这个只用于支持路由的协议家族packet 套接字不支持。 MSG_DONTWAITLinux 2.2 后 开启非阻塞操作。如果操作想要阻塞那么就会返回 EAGAIN 或者 EWOULDBLOCK 错误。这个行为和设置 O_NONBLOCK 标记通过 fcntl(2) F_SETFL 操作行为类似但是 MSG_DONTWAIT 只对当前调用生效而 O_NONBLOCK 是设置到打开文件描述上参考 open(2)这会影响调用进程中的所有线程以及其他持有指向该打开文件描述的文件描述符的进程。 MSG_EORLinux 2.2 后 结束一个记录当支持该语义时用于 SOCK_SEQPACKET 类型的套接字 MSG_MORELinux 2.4.4 后 调用者有更多数据要发送。这个标记用在 TCP 套接字中来获得和 TCP_CORK 套接字选项意向的效果区别是这个标记只对当前调用生效。 MSG_NOSIGNALLinux 2.2 后 如果对端关闭了流套接字不要生成 SIGPIPE 信号不过仍然会返回 EPIPE 错误。这和使用 sigaction(2) 来忽略 SIGPIPE 效果差不多还是 MSG_NONSIGNAL 只对当前调用生效并且忽略 SIGPIPE 设置的是进程属性会影响进程中的所有线程。 MSG_OOB 在支持该带外数据的套接字比如 SOCK_STREAM上发送带外数据。 底层协议必须也支持带外数据传输。 MSG_FASTOPENLinux 3.7 后 尝试 TCP 快速打开RFC7413并发送在 SYN 中发送数据就像 connect(2) 和 write(2) 合并一样进行了隐式的 connect(2) 操作。它会一直阻塞知道数据被缓存并且握手结束。对于一个非阻塞套接字它会返回缓存数据的大小并且发送一个 SYN 包。如果本地 cookie 不可用它会返回 EINPROGRESS并自动发送一个 SYN 带着快速打开 cookie 请求。调用者需要在新连接的套接字上重新发送数据。发生错误时它会在握手失败时设置和 connect(2) 相同的 errno。这个标记需要 sysctl net.ipv4.tcp_fastopen 来开启 TCP 快速打开客户端支持。 参考 tcp(7) TCP_FASTOPEN_CONNECT 套接字选项来查看一些可选的方法。
sendmsg() sendmsg() 使用的 msghdr 结构定义如下 struct msghdr {void *msg_name; /* Optional address */socklen_t msg_namelen; /* Size of address */struct iovec *msg_iov; /* Scatter/gather array */size_t msg_iovlen; /* # elements in msg_iov */void *msg_control; /* Ancillary data, see below */size_t msg_controllen; /* Ancillary data buffer len */int msg_flags; /* Flags (unused) */}; msg_name 字段用来指定非连接数据包类型套接字的目标地址它指向一个包含地址的缓冲区msg_namelen 字段应该设置为地址的大小。对于连接套接字这些字段应该对应的设置为 NULL 和 0。 msg_iov 和 msg_ivolen 字段指定了 scatter-gether 区域和 writev(2) 类似。 我们可以使用 msg_control 和 msg_controllen 成员发送控制信息辅助数据内核能够处理套接字最大的控制缓冲区大小由 /proc/sys/net/core/optmem_max 指定参考 socket(7)。对于其他域套接字关于辅助数据的信息可以参考 unix(7) 和 ip(7)。 msg_flags 字段忽略。
5.返回值 调用成功时返回已发送数据的字节数。 发生错误时返回 -1并设置errno 来指示错误类型。 下面这些标准错误值是由套接字层生成的其他错误可能会由底层协议模块产生并返回具体可以参考对应的手册页。 错误值定义如下
EACCESS特定于由路径指定的 UNIX 域套接字目的套接字写权限被拒绝或者在目录前缀下的搜索权限被拒绝 EAGAIN/EWOULDBLOCK套接字被设置为非阻塞但是请求操作打算阻塞。POSIX.1-2021 允许随意哪个错误都可以并且不假定两个值相等所以移植程序应该对每个值都进行判断。EAGAIN网络域数据报套接字sockfd 指定的套接字还没有绑定到地址并且在尝试绑定到临时端口时临时端口用尽了。可以看 /proc/sys/net/ipv4/ip_local_port_rang 的讨论EALREADY另一个快速打开Fast Open正在进行中EBADFsockfd 不是一个打开的文件描述ECONNRESET对端重置了连接EDESTADDRREQ套接字不是连接模式并且没有设置对端地址EFAULT参数中指定了用户空间不合法的地址EINTR数据发送完成前有信号发生参考 signal(7)EINVAL参数不合法EISCONN连接模式的套接字早已经连接过了但是又指定了接收者。目前要么返回这个错误要么直接忽略掉接收者参数EMSGSIZE套接字类型要求消息自动发送但是消息的大小却使得这个无法完成ENOBUFS网络接口输出队列满了。这个通常指示接口已经停止发送但可能导致传输堵塞。正常情况下这个不会在 Linux 上发生当设备队列溢出时数据包会偷偷的被丢掉。ENOMEM没有内存了ENOTCONN套接字没连接也没有指定目标地址ENOTSOCKsockfd 文件描述符没有指向一个套接字EOPNOTSUPPflags 里面有些位设置不正确EPIPE面向连接的套接字在本地被关闭这种情况下进程也会收到 SIGPIP 信号除非我们设置了 MSG_NOSIGNAL。
6.注意 参考 sendmmsg(2) 来查阅更多 Linux 系统用于一次调用传输多个数据包的信息。 Linux 系统可能返回 EPIPE 而不是 ENOTCONN。
7.代码 Server program#include netdb.h#include stdio.h#include stdlib.h#include string.h#include sys/socket.h#include sys/types.h#include unistd.h#define BUF_SIZE 500intmain(int argc, char *argv[]){int sfd, s;char buf[BUF_SIZE];ssize_t nread;socklen_t peer_addrlen;struct addrinfo hints;struct addrinfo *result, *rp;struct sockaddr_storage peer_addr;if (argc ! 2) {fprintf(stderr, Usage: %s port\n, argv[0]);exit(EXIT_FAILURE);}memset(hints, 0, sizeof(hints));hints.ai_family AF_UNSPEC; /* Allow IPv4 or IPv6 */hints.ai_socktype SOCK_DGRAM; /* Datagram socket */hints.ai_flags AI_PASSIVE; /* For wildcard IP address */hints.ai_protocol 0; /* Any protocol */hints.ai_canonname NULL;hints.ai_addr NULL;hints.ai_next NULL;s getaddrinfo(NULL, argv[1], hints, result);if (s ! 0) {fprintf(stderr, getaddrinfo: %s\n, gai_strerror(s));exit(EXIT_FAILURE);}/* getaddrinfo() returns a list of address structures.Try each address until we successfully bind(2).If socket(2) (or bind(2)) fails, we (close the socketand) try the next address. */for (rp result; rp ! NULL; rp rp-ai_next) {sfd socket(rp-ai_family, rp-ai_socktype,rp-ai_protocol);if (sfd -1)continue;if (bind(sfd, rp-ai_addr, rp-ai_addrlen) 0)break; /* Success */close(sfd);}freeaddrinfo(result); /* No longer needed */if (rp NULL) { /* No address succeeded */fprintf(stderr, Could not bind\n);exit(EXIT_FAILURE);}/* Read datagrams and echo them back to sender. */for (;;) {char host[NI_MAXHOST], service[NI_MAXSERV];peer_addrlen sizeof(peer_addr);nread recvfrom(sfd, buf, BUF_SIZE, 0,(struct sockaddr *) peer_addr, peer_addrlen);if (nread -1)continue; /* Ignore failed request */s getnameinfo((struct sockaddr *) peer_addr,peer_addrlen, host, NI_MAXHOST,service, NI_MAXSERV, NI_NUMERICSERV);if (s 0)printf(Received %zd bytes from %s:%s\n,nread, host, service);elsefprintf(stderr, getnameinfo: %s\n, gai_strerror(s));if (sendto(sfd, buf, nread, 0, (struct sockaddr *) peer_addr,peer_addrlen) ! nread){fprintf(stderr, Error sending response\n);}}} Client program#include netdb.h#include stdio.h#include stdlib.h#include string.h#include sys/socket.h#include sys/types.h#include unistd.h#define BUF_SIZE 500intmain(int argc, char *argv[]){int sfd, s;char buf[BUF_SIZE];size_t len;ssize_t nread;struct addrinfo hints;struct addrinfo *result, *rp;if (argc 3) {fprintf(stderr, Usage: %s host port msg...\n, argv[0]);exit(EXIT_FAILURE);}/* Obtain address(es) matching host/port. */memset(hints, 0, sizeof(hints));hints.ai_family AF_UNSPEC; /* Allow IPv4 or IPv6 */hints.ai_socktype SOCK_DGRAM; /* Datagram socket */hints.ai_flags 0;hints.ai_protocol 0; /* Any protocol */s getaddrinfo(argv[1], argv[2], hints, result);if (s ! 0) {fprintf(stderr, getaddrinfo: %s\n, gai_strerror(s));exit(EXIT_FAILURE);}/* getaddrinfo() returns a list of address structures.Try each address until we successfully connect(2).If socket(2) (or connect(2)) fails, we (close the socketand) try the next address. */for (rp result; rp ! NULL; rp rp-ai_next) {sfd socket(rp-ai_family, rp-ai_socktype,rp-ai_protocol);if (sfd -1)continue;if (connect(sfd, rp-ai_addr, rp-ai_addrlen) ! -1)break; /* Success */close(sfd);}freeaddrinfo(result); /* No longer needed */if (rp NULL) { /* No address succeeded */fprintf(stderr, Could not connect\n);exit(EXIT_FAILURE);}/* Send remaining command-line arguments as separatedatagrams, and read responses from server. */for (size_t j 3; j argc; j) {len strlen(argv[j]) 1;/* 1 for terminating null byte */if (len BUF_SIZE) {fprintf(stderr,Ignoring long message in argument %zu\n, j);continue;}if (write(sfd, argv[j], len) ! len) {fprintf(stderr, partial/failed write\n);exit(EXIT_FAILURE);}nread read(sfd, buf, BUF_SIZE);if (nread -1) {perror(read);exit(EXIT_FAILURE);}printf(Received %zd bytes: %s\n, nread, buf);}exit(EXIT_SUCCESS);}
