C语言实现TCP通信_c scrip代码 读取tcp

C语言通过socket编程实现TCP通信

服务端客户端通信例子：socket tcp 通信1，socket tcp通信2，udp使用讲解，socket udp通信例子

1. TCP/IP协议

叫做传输控制/网际协议，又叫网络通信协议。实际上，它包含上百个功能的协议，如ICMP（互联网控制信息协议）、FTP（文件传输协议）、UDP（用户数据包协议）、ARP（地址解析协议）等。TCP负责发现传输的问题，一旦有问题就会发出重传信号，直到所有数据安全正确的传输到目的地。

2.套接字（socket）：

在网络中用来描述计算机中不同程序与其他计算机程序的通信方式。socket其实是一种特殊的IO接口，也是一种文件描述符。
1

套接字分为三类：

流式socket（SOCK_STREAM）：流式套接字提供可靠、面向连接的通信流；它使用TCP协议，从而保证了数据传输的正确性和顺序性。

数据报socket（SOCK_DGRAM）：数据报套接字定义了一种无连接的服务，数据通过相互独立的保温进行传输，是无序的，并且不保证是可靠、无差错的。它使用的数据报协议是UDP。

原始socket：原始套接字允许对底层协议如IP或ICMP进行直接访问，它功能强大但使用复杂，主要用于一些协议的开发。
1
2
3
4
5

套接字由三个参数构成：IP地址，端口号，传输层协议。这三个参数用以区分不同应用程序进程间的网络通信与连接。

套接字的数据结构：C语言进行套接字编程时，常会使用到sockaddr数据类型和sockaddr_in数据类型，用于保存套接字信息。

两种结构体分别表示如下：

struct sockaddr
{
 
//地址族，2字节
unsigned short sa_family;
 
//存放地址和端口，14字节
char sa_data[14];
 
}
 
 
struct sockaddr_in
{
 
//地址族
short int sin_family;
 
//端口号(使用网络字节序)
unsigned short int sin_port;
 
//地址
struct in_addr sin_addr;
 
//8字节数组，全为0，该字节数组的作用只是为了让两种数据结构大小相同而保留的空字节
unsigned char sin_zero[8]
 
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

对于sockaddr，大部分的情况下只是用于bind，connect，recvfrom，sendto等函数的参数，指明地址信息，在一般编程中，并不对此结构体直接操作。而用sockaddr_in来替。

两种数据结构中，地址族都占2个字节，

常见的地址族有：AF_INET，AF_INET6AF_LOCAL。

这里要注意字节序的问题，最好使用以下函数来对端口和地址进行处理：

1. uint16_t htons(uint16_t host16bit) 把16位值从主机字节序转到网络字节序

   uint32_t htonl(uint32_t host32bit) 把32位值从主机字节序转到网络字节序

2. uint16_t ntohs(uint16_t net16bit) 把16位值从网络字节序转到主机字节序

   uint32_t ntohs(uint32_t net32bit) 把32位值从网络字节序转到主机字节序

使用socket进行TCP通信时，经常使用的函数有：

3.下面给出server和client的两个例子

更详细的例子

服务端：

/socket tcp服务器端/

#include <sys/stat.h>
 
#include <fcntl.h>
 
#include <errno.h>
 
#include <netdb.h>
 
#include <sys/types.h>
 
#include <sys/socket.h>
 
#include <netinet/in.h>
 
#include <arpa/inet.h>
 
#include <stdio.h>
 
#include <string.h>
 
#include <stdlib.h>
 
#include <unistd.h>
 
#define SERVER_PORT 6666
 
/*
监听后，一直处于accept阻塞状态，
直到有客户端连接，
当客户端如数quit后，断开与客户端的连接
*/
 
int main()
 
{
 
//调用socket函数返回的文件描述符
 
int serverSocket;
 
//声明两个套接字sockaddr_in结构体变量，分别表示客户端和服务器
 
struct sockaddr_in server_addr;
 
struct sockaddr_in clientAddr;
 
int addr_len = sizeof(clientAddr);
 
int client;
 
char buffer[200];
 
int iDataNum;
 
//socket函数，失败返回-1
 
//int socket(int domain, int type, int protocol);
 
//第一个参数表示使用的地址类型，一般都是ipv4，AF_INET
 
//第二个参数表示套接字类型：tcp：面向连接的稳定数据传输SOCK_STREAM
 
//第三个参数设置为0
 
if((serverSocket = socket(AF_INET, SOCK_STREAM, 0)) < 0)
 
{
 
perror("socket");
 
return 1;
 
}
 
bzero(&server_addr, sizeof(server_addr));
 
//初始化服务器端的套接字，并用htons和htonl将端口和地址转成网络字节序
 
server_addr.sin_family = AF_INET;
 
server_addr.sin_port = htons(SERVER_PORT);
 
//ip可是是本服务器的ip，也可以用宏INADDR_ANY代替，代表0.0.0.0，表明所有地址
 
server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
 
//对于bind，accept之类的函数，里面套接字参数都是需要强制转换成(struct sockaddr *)
 
//bind三个参数：服务器端的套接字的文件描述符，
 
if(bind(serverSocket, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0)
 
{
 
perror("connect");
 
return 1;
 
}
 
//设置服务器上的socket为监听状态
 
if(listen(serverSocket, 5) < 0)
 
{
 
perror("listen");
 
return 1;
 
}
 
while(1)
 
{
 
printf("监听端口: %d\n", SERVER_PORT);
 
//调用accept函数后，会进入阻塞状态
 
//accept返回一个套接字的文件描述符，这样服务器端便有两个套接字的文件描述符，
 
//serverSocket和client。
 
//serverSocket仍然继续在监听状态，client则负责接收和发送数据
 
//clientAddr是一个传出参数，accept返回时，传出客户端的地址和端口号
 
//addr_len是一个传入-传出参数，传入的是调用者提供的缓冲区的clientAddr的长度，以避免缓冲区溢出。
 
//传出的是客户端地址结构体的实际长度。
 
//出错返回-1
 
client = accept(serverSocket, (struct sockaddr*)&clientAddr, (socklen_t*)&addr_len);
 
if(client < 0)
 
{
 
perror("accept");
 
continue;
 
}
 
printf("等待消息...\n");
 
//inet_ntoa ip地址转换函数，将网络字节序IP转换为点分十进制IP
 
//表达式：char *inet_ntoa (struct in_addr);
 
printf("IP is %s\n", inet_ntoa(clientAddr.sin_addr));
 
printf("Port is %d\n", htons(clientAddr.sin_port));
 
while(1)
 
{
 
printf("读取消息:");
 
buffer[0] = '\0';
 
iDataNum = recv(client, buffer, 1024, 0);
 
if(iDataNum < 0)
 
{
 
perror("recv null");
 
continue;
 
}
 
buffer[iDataNum] = '\0';
 
if(strcmp(buffer, "quit") == 0)
 
break;
 
printf("%s\n", buffer);
 
 
 
printf("发送消息:");
 
scanf("%s", buffer);
 
printf("\n");
 
send(client, buffer, strlen(buffer), 0);
 
if(strcmp(buffer, "quit") == 0)
 
break;
 
}
 
}
 
close(serverSocket);
 
return 0;
 
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207

客户端：

/socket tcp客户端/

#include <sys/stat.h>
 
#include <fcntl.h>
 
#include <errno.h>
 
#include <netdb.h>
 
#include <sys/types.h>
 
#include <sys/socket.h>
 
#include <netinet/in.h>
 
#include <arpa/inet.h>
 
#include <stdio.h>
 
#include <string.h>
 
#include <stdlib.h>
 
#include <unistd.h>
 
#define SERVER_PORT 6666
 
/*
连接到服务器后，会不停循环，等待输入，
输入quit后，断开与服务器的连接
*/
 
int main()
 
{
 
//客户端只需要一个套接字文件描述符，用于和服务器通信
 
int clientSocket;
 
//描述服务器的socket
 
struct sockaddr_in serverAddr;
 
char sendbuf[200];
 
char recvbuf[200];
 
int iDataNum;
 
if((clientSocket = socket(AF_INET, SOCK_STREAM, 0)) < 0)
 
{
 
perror("socket");
 
return 1;
 
}
 
serverAddr.sin_family = AF_INET;
 
serverAddr.sin_port = htons(SERVER_PORT);
 
//指定服务器端的ip，本地测试：127.0.0.1
 
//inet_addr()函数，将点分十进制IP转换成网络字节序IP
 
serverAddr.sin_addr.s_addr = inet_addr("127.0.0.1");
 
if(connect(clientSocket, (struct sockaddr *)&serverAddr, sizeof(serverAddr)) < 0)
 
{
 
perror("connect");
 
return 1;
 
}
 
printf("连接到主机...\n");
 
while(1)
 
{
 
printf("发送消息:");
 
scanf("%s", sendbuf);
 
printf("\n");
 
send(clientSocket, sendbuf, strlen(sendbuf), 0);
 
 
 
if(strcmp(sendbuf, "quit") == 0)
 
break;
 
printf("读取消息:");
 
recvbuf[0] = '\0';
 
iDataNum = recv(clientSocket, recvbuf, 200, 0);
 
recvbuf[iDataNum] = '\0';
 
printf("%s\n", recvbuf);
 
}
 
close(clientSocket);
 
return 0;
 
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116