TCP的pop网络模式
1、tcp连接的状态有以下11种
- CLOSED：关闭状态
- LISTEN：服务端状态，等待客户端发起连接请求
- SYN_SENT：客户端已发送同步连接请求，等待服务端相应
- SYN_RECEIVED：服务器收到客户端的SYN请请求，并发送自己的SYN响应，并等待客户端对这个SYN+ACK的确认（等待客户端连接确认）；
- ESTABLISHED：双方完成三次握手，连接成功，可以进行数据传输；
- FIN_WAIT_1：主动关闭连接的一方（通常是客户端）已经发送FIN报文，但是还未收到对方的确认。此时仍可以进行数据接收；
- FIN_WAIT_2：主动关闭一方收到了对方的FIN确认，但是没收到对方的FIN，进入半连接状态，仅能接收数据；
- CLOSE_WAIT：被动关闭连接的一方已经收到FIN，并发送了确认，但尚关闭连接，等待应用层释放资源；
- CLOSING：双方都发送了关闭请求，都在等待对方确认；
- LAST_ACK：被动关闭的一方发送了FIN，等待最后的ACK来关闭连接；
- TIME_WAIT：主动关闭方发送完FIN，并收到对方的FIN+ACK后进入该状态，等待足够长的时间确保对方能够收到确认后再关闭连接；
- 所有连接终止程序完成后，套接字回到CLOSED状态
tcp所有的状态转换图如下：
2、正常的TCP连接和断开状态转换：
客户端状态转换过程
CLOSED->SYN_SENT->ESTABLISHED->FIN_WAIT_1->FIN_WAIT_2->TIME_WAIT->CLOSED
服务端状态转换过程
CLOSED->LISTEN->SYN_RCVD->ESTABLISHED->CLOSE_WAIT->LAST_ACK->CLOSED
3、其他状态转换过程
同时发送断开连接
ESTABLISHED->FIN_WAIT_1->CLOSING->TIME_WAIT->CLOSED
同时去发送连接（pop网络模式）
CLOSED->SYN_SENT->SYN_RCVD->ESTABLISHED
Peer-to-Peer，中文译为“对等网络”或“点对点技术”，是一种分布式应用架构，其中每个参与者（称为“节点”）都能够同时作为客户端和服务器，直接与其它节点进行数据交互，而不需要通过中央服务器中转。P2P网络的关键特征是去中心化和资源的分散共享，这使得网络更加健壮，更能适应大规模的数据交换和共享；
pop网络模式的代码实现：
#include <sys/socket.h>
#include <errno.h>
#include <netinet/in.h>
#include <stdlib.h>
#include <unistd.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
#include <sys/poll.h>
#include <arpa/inet.h>
int bind_localaddr(const char *ip, short port) {
int connfd = socket(AF_INET, SOCK_STREAM, 0);
struct sockaddr_in tcpclient_addr;
memset(&tcpclient_addr, 0, sizeof(struct sockaddr_in));
tcpclient_addr.sin_family = AF_INET;
tcpclient_addr.sin_addr.s_addr = htonl(INADDR_ANY);
tcpclient_addr.sin_port = htons(port);
if (-1 == bind(connfd, (struct sockaddr*)&tcpclient_addr, sizeof(struct sockaddr))) {
perror("bind");
return -1;
}
return connfd;
}
int connect_tcpserver(int connfd, const char *ip, short port) {
struct sockaddr_in tcpserver_addr;
memset(&tcpserver_addr, 0, sizeof(struct sockaddr_in));
tcpserver_addr.sin_family = AF_INET;
tcpserver_addr.sin_addr.s_addr = inet_addr(ip);
tcpserver_addr.sin_port = htons(port);
int ret = connect(connfd, (struct sockaddr*)&tcpserver_addr, sizeof(struct sockaddr_in));
if (ret) {
return -1;
}
return connfd;
}
void *client_thread(void *arg) {
int clientfd = *(int *)arg;
while (1) {
printf(" client > ");
char buffer[128] = {0};
scanf("%s", buffer);
if (strcmp(buffer, "quit") == 0) {
break;
}
int len = strlen(buffer);
printf("count: %d, send: %s\n", len, buffer);
send(clientfd, buffer, len, 0);
}
}
int main(int argc, char *argv[]) {
if (argc < 3) {
printf("arg\n");
return -1;
}
char *ip = argv[1];
int port = atoi(argv[2]);
int sockfd = bind_localaddr("0.0.0.0", 8000);
while (1) {
int ret = connect_tcpserver(sockfd, ip, port);
if (ret < 0) {
usleep(1);
continue;
}
break;
}
printf("connect success\n");
pthread_t thid;
pthread_create(&thid, NULL, client_thread, &sockfd);
struct pollfd fds[1] = {0};
fds[0].fd = sockfd;
fds[0].events = POLLIN;
while (1) {
int nready = poll(fds, 1, -1);
if (fds[0].revents & POLLIN) {
char buffer[128] = {0};
int count = recv(sockfd, buffer, 128, 0);
if (count == 0) {
fds[0].fd = -1;
fds[0].events = 0;
close(sockfd);
break;
}
printf("recv --> count: %d, buffer: %s\n", count, buffer);
}
}
}
