一、TCP连接通讯示意图

二、TCP/UDP通讯使用到的套接字
TCP:流式套接字,面向连接,保证传输的数据是顺序的正确的。
 UDP:数据报套接字,面向无连接,数据通过相互独立的报文进行传播,是无序的,并且不保证可靠。
套接字工作过程如下:服务器首先启动,通过调用socket()建立一个套接字,然后调用bind()将该套接字和本地网络地址联系在一起,再调用listen()使套接字做好帧听的准备,并规定它的请求队列的长度,之后调用accept()来接收连接。客户端在建立好套接字后就可调用connect()和服务器建立连接。连接一旦建立,客户机和服务器之间就可以通过调用read()和write()来发送和接收数据。最后,待数据传送结束后,双方调用close关闭套接字。
1、int socket(int domain, int type, int protocol);
 作用:用于创建网络连接套接字。
 参数:
    domain:用于设置网络通讯的域,函数根据这个参数选择通讯协议的族,通常为AF_INET,表示ipv4;
    type:  用于设置套接字通讯的类型,主要有SOCK_STREAM(流式套接字,支持TCP)和SOCK_DGRAM(数据包报文,支持UDP
    protocol: 用于指定协议的特定类型,通常某协议只有一种特定的类型,该参数设置为0。
返回值:
     成功,返回套接字描述符;失败,返回-1。
2、int bind(int sockfd, struct sockaddr *my_addr, int addrlen);
 作用:用来指定一个套接字使用的端口。
 参数:sockfd 是由socket()函数返回的套接字描述符。
            my_addr 是一个指向struct sockaddr的指针,包含地址信息:名称、端口和IP地址。
            addrlen 可以设置为sizeof(struct sockaddr)。
 返回值:成功返回0,出错返回-1。
3、int connect(int sockfd, const struct sockaddr *addr, socklen_t addrlen);
 作用:用于连接服务器。
 参数:
            sockfd:socket()创建成功之后返回的网络描述符。
            addr:需要连接的服务器的IP地址/端口号/网络类型。
            addrlen:addr长度。
 返回值:成功,返回0;失败,返回-1。
     
 4、int listen(int sockfd, int backlog);
 作用:等待别人连接,进行系统侦听请求的函数。
 参数:
           sockfd是一个套接字描述符,由socket()系统获得。
           backlog是未经过处理的连接请求队列可以容纳的最大数目。
 返回值:成功,返回0;失败,返回-1。
 补充:每一个连入请求都要进入一个连入请求队列,等待listen的程序调用accept(),函数来接收这个连接。当系统还没有调用accept()函数的时候,若有多个连接,那么本地能够等待的最大数目就是backlog的数值,通常设置为5到10之间。
5、int accept(int sockfd, void *addr, int *addrlen);
 作用:当前连接处于listen状态,用来接受远程计算机的连接。
 参数:sockfd 是正在listen()的一个套接字描述符。
            addr 指向struct sockaddr_in结构的指针;里面存储着远程连接过来的计算机信息。
            addrlen sizeof(struct sockaddr_in)。
 返回值:成功,返回0;失败,返回-1。
    ssize_t send(int sockfd, const void *buf, size_t len, int flags);
 作用:通过连接的套接字流进行通讯的函数。
 参数:sockfd 是代表与远程程序连接的套接字描述符。
            msg 是一个指针,指向想要发送的信息的地址。
            len 发送信息的长度。
            flag 发送标记,一般设置为0。
返回值:返回发送数据的长度,如果发送数据的长度大于发送的最大长度,则实际发送长度为最大发送长度。
    ssize_t recv(int sockfd, void *buf, int len, unsigned int flags);
 作用:通过连接的套接字流进行通讯的函数。
 参数:sockfd 是代表与远程程序连接的套接字描述符。
            buf  是一个指针,指向想要存储数据的内存缓存区域。
            len  缓存区的最大尺寸。
            flag 发送标记,一般设置为0。
 返回值:返回它所真正收到的数据的长度,-1代表发生了错误。
    int sendto(int sockfd, const void *msg, size_t len, unsigned int flags,const struct sockaddr *to, int tolen);
     int recvfrom(int sockfd, void *buf, size_t len, unsigned int flags, struct sockaddr *from, int *fromlen);
 作用:这两个函数是进行无连接的UDP通讯时使用,通过这两个函数,数据会在没有建立任何连接的网络上传输。
 参数:与send和rece类似。
6、int close(int fd);
 作用:关闭一个连接。
 参数:
       fd,需要关闭的连接的套接字描述符。
三、客户端/服务端通讯示例
client.c
#include <stdio.h>
 #include <sys/socket.h>
 #include <sys/types.h>
 #include <arpa/inet.h>
 #include <string.h>
#define SERVER_ADDR  “192.168.1.10”
 #define SERVER_PORT  9003
 #define CMD_REGISTER    1001  //注册学生信息
 #define CMD_CHECK       1002  //检验学生信息
 #define CMD_GETINFO     1003  //获取学生信息
 #define STAT_OK         30    //回复OK
 #define STAT_ERR        31    //回复出错
char sendbuf[100];
 char recvbuf[100];
 typedef struct commu
 {
     char name[20];
     int age;
     int cmd;
     int stat;
 }info;
int main(void)
 {
   //第一步,先sock打开文件描述符
   int sockfd = -1,ret=-1;
   struct sockaddr_in seraddr={0};
   struct sockaddr_in cliaddr={0};
  //第一步:socket
   sockfd=socket(AF_INET, SOCK_STREAM, 0);
   if(-1 == sockfd)
   {
        perror(“socket”);
        return -1;
   }
  //第二步,connect链接服务器
   seraddr.sin_family = AF_INET;               //设置地址族为IPv4
   seraddr.sin_addr.s_addr = inet_addr(SERVER_ADDR);  //设置IP地址
   seraddr.sin_port = htons(SERVER_PORT);            //设置地址的端口号信息
   ret=connect(sockfd,(const struct sockaddr *)&seraddr,sizeof(seraddr));
   if(ret<0)
   {
        perror(“listen”);
        return -1;
   } 
   printf(“成功建立连接”);
  while (1)
   {
     // 回合中第1步:客户端给服务器发送信息
     info st1;
     printf(“请输入学生姓名\n”);
     scanf(“%s”, st1.name);
     printf(“请输入学生年龄”);
     scanf(“%d”, &st1.age);
     st1.cmd = CMD_REGISTER;
     //printf(“刚才输入的是:%s\n”, sendbuf);
     ret = send(sockfd, &st1, sizeof(info), 0);
     printf(“发送了1个学生信息\n”);
         
     // 回合中第2步:客户端接收服务器的回复
     memset(&st1, 0, sizeof(st1));
     ret = recv(sockfd, &st1, sizeof(st1), 0);
     
     // 回合中第3步:客户端解析服务器的回复,再做下一步定夺
    return 0;
 }
serive.c
#define SERPORT        9003
 #define SERADDR        “192.168.1.141”        // ifconfig看到的
 #define BACKLOG        100
 #define CMD_REGISTER    1001    // 注册学生信息
 #define CMD_CHECK        1002    // 检验学生信息
 #define CMD_GETINFO        1003    // 获取学生信息
 #define STAT_OK            30        // 回复ok
 #define STAT_ERR        31        // 回复出错了
char recvbuf[100];
 typedef struct commu
 {
     char name[20];        // 学生姓名
     int age;            // 学生年龄
     int cmd;            // 命令码
     int stat;            // 状态信息,用来回复
 }info;
int main(void)
 {
     // 第1步:先socket打开文件描述符
     int sockfd = -1, ret = -1, clifd = -1;
     socklen_t len = 0;
     struct sockaddr_in seraddr = {0};
     struct sockaddr_in cliaddr = {0};
     char ipbuf[30] = {0};
     
     sockfd = socket(AF_INET, SOCK_STREAM, 0);
     if (-1 == sockfd)
     {
         perror(“socket”);
         return -1;
     }
     printf(“socketfd = %d.\n”, sockfd);
     
     // 第2步:bind绑定sockefd和当前电脑的ip地址&端口号
     seraddr.sin_family = AF_INET;        // 设置地址族为IPv4
     seraddr.sin_port = htons(SERseraseraddrPORT);    // 设置地址的端口号信息
     seraddr.sin_addr.s_addr = inet_addr(SERADDR);    // 设置IP地址
     ret = bind(sockfd, (const struct sockaddr *)&seraddr, sizeof(seraddr));
     if (ret < 0)
     {
         perror(“bind”);
         return -1;
     }
     printf(“bind success.\n”);
     
     // 第三步:listen监听端口
     ret = listen(sockfd, BACKLOG);        // 阻塞等待客户端来连接服务器
     if (ret < 0)
     {
         perror(“listen”);
         return -1;
     }
     
     // 第四步:accept阻塞等待客户端接入
     clifd = accept(sockfd, (struct sockaddr *)&cliaddr, &len);
     printf(“连接已经建立,client fd = %d.\n”, clifd);
     
     // 客户端反复给服务器发
     while (1)
     {
         info st;
         // 回合中第1步:服务器收
         ret = recv(clifd, &st, sizeof(info), 0);
        // 回合中第2步:服务器解析客户端数据包,然后干活,
         if (st.cmd == CMD_REGISTER)
         {
             printf(“用户要注册学生信息\n”);
             printf(“学生姓名:%s,学生年龄:%d\n”, st.name, st.age);
             // 在这里服务器要进行真正的注册动作,一般是插入数据库一条信息
             
             // 回合中第3步:回复客户端
             st.stat = STAT_OK;
             ret = send(clifd, &st, sizeof(info), 0);
         }
     }
     return 0;
 }
