欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Socket套接字编程(TCP基本编程)

程序员文章站 2022-07-14 20:30:19
...

Socket函数

#include <sys/types.h> 
#include <sys/socket.h>
int socket(int domain, int type, int protocol);

创建一个套接字用于通信。

domain :指定通信协议族(protocolfamily)

Socket套接字编程(TCP基本编程)

type:指定socket类型,流式套接字SOCK_STREAM,数据报套接字SOCK_DGRAM,原始套接字SOCK_RAW

Socket套接字编程(TCP基本编程)

protocol :协议类型

Socket套接字编程(TCP基本编程)

TCP客户端/服务器流程图

Socket套接字编程(TCP基本编程)

bind函数

#include <sys/types.h> 
#include <sys/socket.h>
int bind(int sockfd, const struct sockaddr *addr,socklen_t addrlen);

用于绑定一个本地地址到套接字。

参数说明(后面函数参数同此)

sockfd:socket函数返回的套接字

addr:要绑定的地址,并将其转化为通用地址结构

addrlen:地址长度

listen函数

#include <sys/types.h>
#include <sys/socket.h>
int listen(int sockfd, int backlog);

listen函数应该在调用socket和bind函数之后,调用函数accept之前调用。

对于给定的监听套接字,内核要维护两个队列:

1、未完成链接队列:已由客户端发出并到达服务器,服务器正在等待完成相应的TCP三路握手过程,套接字处于SYN_RCVD状态

2、已完成链接队列:每个已完成TCP三路握手过程的客户端,套接字处于ESTABLISHED状态。

Socket套接字编程(TCP基本编程)

三路握手过程如图

Socket套接字编程(TCP基本编程)

accept函数

#include <sys/types.h>
#include <sys/socket.h>
int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);

从已完成连接队列返回第一个连接,产生一个socket套接字用于与客户端进行通信,如果已完成连接队列为空,则阻塞。

connect函数

#include <sys/types.h>
#include <sys/socket.h>
int connect(int sockfd, const struct sockaddr *addr,socklen_t addrlen);

建立一个连接至addr所指定(客户端)的套接字。

代码实例

服务器端代码

#include<stdio.h>
#include<unistd.h>
#include<stdlib.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<string.h>
int main(int argc,char * argv[])
{
    int listenfd,connfd;
    char sendbuf[100]= {"got your msg"},revbuf[100]= {};
    struct sockaddr_in ser,clt;
    socklen_t len=sizeof(clt);
    listenfd=socket(AF_INET,SOCK_STREAM,0);
    ser.sin_family = AF_INET;
    ser.sin_port = htons(8001);
    ser.sin_addr.s_addr = inet_addr("127.0.0.1");
    if(bind(listenfd,(struct sockaddr*)&ser,sizeof(ser))<0)
    {
        printf("bind failed!\n");
        exit(0);
    }
    if(listen(listenfd,SOMAXCONN)<0)
    {
        printf("listen failed!\n");
        exit(0);
    }
    connfd=accept(listenfd,(struct sockaddr*)&clt,(socklen_t *)&len);
    if(connfd==-1)
    {
        printf("connect failed!\n");
        exit(0);
    }
    for(;;)
    {
        int ret=read(connfd,revbuf,sizeof(revbuf));
        if(ret<0)
        {
            printf("read failed!\n");
            exit(0);
        }
        else if(ret==0)
        {
            printf("client closed\n");
            exit(0);
        }
        printf("server revmsg:%s\n",revbuf);
        write(connfd,sendbuf,sizeof(sendbuf));
        memset(revbuf,0,sizeof(revbuf));
    }
    close(listenfd);
    close(connfd);
    return 0;
}

客户端代码

#include<stdio.h>
#include<unistd.h>
#include<stdlib.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<string.h>
int main(int argc,char *argv[])
{
    struct sockaddr_in user;
    int sockfd;
    char sendbuf[100],revbuf[100];
    sockfd=socket(AF_INET,SOCK_STREAM,0);
    if(sockfd==-1)
    {
        printf("socket failed!\n");
        exit(0);
    }
    user.sin_family = AF_INET;
    user.sin_port = htons(8001);
    user.sin_addr.s_addr = inet_addr("127.0.0.1");
    if ( connect(sockfd, (struct sockaddr*) (&user), sizeof(user)) < 0)
    {
        perror("connect failed!\n");
        exit(0);
    }
    while(~scanf("%s",sendbuf))
    {
        write(sockfd,sendbuf,sizeof(sendbuf));
        read(sockfd,revbuf,sizeof(revbuf));
        printf("client revmsg:%s\n",revbuf);
        memset(sendbuf,0,sizeof(sendbuf));
        memset(sendbuf,0,sizeof(revbuf));
    }
    close(sockfd);
    return 0;
}

Socket套接字编程(TCP基本编程)

Socket套接字编程(TCP基本编程)

Socket套接字编程(TCP基本编程)

客户端中断关闭

Socket套接字编程(TCP基本编程)

Socket套接字编程(TCP基本编程)

Socket套接字编程(TCP基本编程)