c++ socket编程详解

一、socket介绍

socket是用于实现网络通信的一种机制，是应用层和传输层之间的接口。在c++编程中，socket通常被用于网络编程。

socket的实现需要涉及到一下概念：IP地址、端口号、协议号、socket类型。其中IP地址和端口号用来标识网络上的一台主机，协议号则指定该socket使用的传输层协议，而socket类型则决定了socket通信的方式。

二、socket类型

在c++编程中，socket类型主要有两种，分别是面向连接的流套接字（SOCK_STREAM）和无连接的数据报套接字（SOCK_DGRAM）。

面向连接的流套接字需要在建立连接后进行通信，通信时数据是按顺序传送的且不存在数据边界，适合于可靠传输场景，如HTTP协议；而无连接的数据报套接字无需建立连接便可直接发送数据，数据包是独立的，适合于实时传输场景，如视频会议。

三、socket编程步骤

进行socket编程可分为4个步骤，分别是创建socket、绑定socket、监听socket、接收请求。

1、创建socket

在c++编程中，使用socket()函数可以创建一个socket，函数原型如下：

int socket(int domain, int type, int protocol);

其中domain参数指定socket的协议族，type参数指定socket类型，protocol参数指定socket所使用的传输协议。

例如，使用TCP/IP协议族创建面向连接的流套接字可以使用如下代码：

int sockfd = socket(AF_INET, SOCK_STREAM, 0);

2、绑定socket

绑定socket需要将socket与一个本地IP地址和端口号进行绑定，这样socket才能够被其他主机访问。在c++编程中，可以使用bind()函数进行绑定，函数原型如下：

int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);

其中sockfd参数指定待绑定的socket文件描述符，addr参数指定本地IP地址和端口号，addrlen参数指定addr结构体的长度。

例如，将socket绑定到127.0.0.1的8000端口可以使用如下代码：

struct sockaddr_in addr;
addr.sin_family = AF_INET;
addr.sin_addr.s_addr = htonl(INADDR_ANY);
addr.sin_port = htons(8000);
bind(sockfd, (struct sockaddr *)&addr, sizeof(addr));

3、监听socket

在socket绑定后，需要使用listen()函数开始对该socket进行监听，等待客户端连接。函数原型如下：

int listen(int sockfd, int backlog);

其中sockfd参数指定待监听的socket文件描述符，backlog参数指定可以接受的连接队列的最大长度。

例如，对socket进行监听，并设置最大连接队列长度为10可以使用如下代码：

listen(sockfd, 10);

4、接收请求

当socket处于监听状态时，可以使用accept()函数等待客户端连接并进行数据传输。函数原型如下：

int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);

其中sockfd参数指定待接受连接的socket文件描述符，addr参数用于存储连接的远程IP地址和端口号，addrlen参数指定addr结构体的长度。

例如，接受客户端连接并进行数据传输可以使用如下代码：

struct sockaddr_in client_addr;
int connfd = accept(sockfd, (struct sockaddr *)&client_addr, &addrlen);

四、socket编程示例

下面是一个使用socket编程进行TCP通信的简单示例：

#include 
#include 
#include 
#include 
#include 

#define PORT 8000
#define MAXLINE 1024

using namespace std;

int main() {
    int sockfd, n;
    char sendline[MAXLINE], recvline[MAXLINE];
    struct sockaddr_in server_addr;

    // 创建socket
    sockfd = socket(AF_INET, SOCK_STREAM, 0);

    // 绑定socket
    bzero(&server_addr, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(PORT);
    inet_pton(AF_INET, "127.0.0.1", &server_addr.sin_addr);
    connect(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr));

    // 发送消息
    while (fgets(sendline, MAXLINE, stdin) != nullptr) {
        send(sockfd, sendline, strlen(sendline), 0);
        if ((n = recv(sockfd, recvline, MAXLINE, 0)) == 0) {
            cout << "server closed" << endl;
            break;
        }
        recvline[n] = 0;
        if (fputs(recvline, stdout) == EOF) {
            cout << "fputs error" << endl;
            break;
        }
    }

    // 关闭socket
    close(sockfd);
    return 0;
}

原创文章，作者：小蓝，如若转载，请注明出处：https://www.506064.com/n/150860.html