Linux下的C Socket编程(三)
server端的简单示例
经过前面的client端的学习，我们已经知道了如何创建socket，所以接下来就是去绑定他到具体的一个端口上面去。
绑定socket到一个端口上
bind()函数可以将socket绑定到一个端口上，client可以通过向这个端口发起请求，端口对应的socket便会与client端的socket连接。
#include<stdio.h>
#include<stdlib.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<arpa/inet.h>
int main() {
int socket_desc;
struct sockaddr_in server;
socket_desc = socket(AF_INET, SOCK_STREAM, 0);
if (-1 == socket_desc) {
perror("cannot create socket");
exit(1);
}
// 监听服务器自身
server.sin_addr.s_addr = INADDR_ANY;
server.sin_family = AF_INET;
server.sin_port = htons(8888);
// 绑定到端口
if (bind(socket_desc, (struct sockaddr *)&server, sizeof(server)) < 0) {
perror("cannot bind error");
exit(1);
}
printf("bind success");
close(socket_desc);
return 0;
}
对于
server.sin_addr.s_addr的更多信息可以参考这里
通过将socket绑定到一个确定的端口上，我们接下来要做的便是接收这个端口下的所有数据。
通过上面的实现，可以看出一个端口只能被一个socket使用。
监听端口
在绑定玩socket与端口后，我们还需要去监听端口。为此，我们需要将socket设置在被监听的状态下。listen()被用来将socket设置为被监听的模式下。
listen(socket_desc, 3);
listen(int sockfd, int backlog)可以将socket处于监听的状态。
其参数为:
- int sockfd 设置监听的socket
- int backlog 在当前连接后面允许存在的最大未处理连接数
当监听到新的请求来临时，server需要接收请求建立连接。
接收请求建立连接
函数accept()的作用便是接收请求。
#include<stdio.h>
#include<stdlib.h>
#include<sys/socket.h>
#include<arpa/inet.h>
int main() {
int socket_desc, new_socket, sockaddr_size;
struct sockaddr_in server, client;
// 创建socket
socket_desc = socket(AF_INET, SOCK_STREAM, 0);
if (-1 == socket_desc) {
perror("cannot create socket");
exit(1);
}
server.sin_addr.s_addr = INADDR_ANY;
server.sin_family = AF_INET;
server.sin_port = htons(8888);
// 绑定
if (bind(socket_desc, (struct sockaddr *)&server, sizeof(server)) < 0) {
perror("bind error");
exit(1);
}
// 监听
listen(socket_desc, 5);
puts("waiting for incoming connections....");
// 接受
sockaddr_size = sizeof(struct sockaddr_in);
new_socket = accept(socket_desc, (struct sockaddr *)&client, (socklen_t *)&sockaddr_size);
if (new_socket < 0) {
perror("accept error");
exit(1);
}
puts("connection accepted");
// 先关闭由socket_desc产生的new_socket
close(new_socket);
// 在关闭socket_desc
close(socket_desc);
return 0;
}
运行代码，他将会输出：
waiting for incoming connections....
现在代码已经正常的跑起来了，并且等待请求连接。在另外一个终端内，我们发起一个请求：
telnet 127.0.0.1 8888
在当前的这个终端内将会输出：
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
Connection closed by foreign host.
同时在之前的终端内，server会输出：
waiting for incoming connections....
connection accepted
便可以看到server已经正确的接受了client的连接请求并建立了连接，只是没有后续操作，主机紧接着关闭了这个连接。
连接建立之后便可以顺利的进行双方的通信，这部分的send与recv操作完全一样。
另外：
服务端获取客户端的IP地址
由前面能够知道accept()返回的是结构体sockaddr_in，由此很容易得知client的IP和端口信息。
char *client_ip = inet_ntoa(client.sin_addr);
int client_port = ntohs(client.sin_port);
server端的总结：
#include<stdio.h>
#include<string.h>
#include<stdlib.h>
#include<sys/socket.h>
#include<sys/types.h>
#include<arpa/inet.h>
#include<netinet/in.h>
#include<unistd.h>
int main() {
int socket_desc, new_socket;
struct sockaddr_in server, client;
char *message, get_recv[2000];
// 创建socket
socket_desc = socket(AF_INET, SOCK_STREAM, 0);
if (-1 == socket_desc) {
perror("cannot create socket");
exit(1);
}
server.sin_addr.s_addr = INADDR_ANY;
server.sin_family = AF_INET;
server.sin_port = htons(8888);
// 绑定
if (bind(socket_desc, (struct sockaddr *)&server, sizeof(server)) < 0) {
perror("cannot bind");
exit(1);
}
puts("bind success");
// 监听
listen(socket_desc, 5);
puts("waiting for incoming connections....");
// 接受连接
socklen_t sockaddr_size = sizeof(client);
new_socket = accept(socket_desc, (struct sockaddr *)&client, &sockaddr_size);
if (new_socket < 0) {
perror("accept error");
exit(1);
}
puts("connection accepted");
// 发送数据
message = "hello world\r\n";
if (send(new_socket, message, strlen(message), 0) < 0) {
perror("send message error");
return 1;
}
puts("send message success");
if (recv(new_socket, get_recv, 2000, 0) < 0) {
perror("recv error");
return 2;
}
puts("recv success");
puts(get_recv);
// 关闭
close(new_socket);
close(socket_desc);
return 0;
}
到目前为止，server端的主要操作都已经完成，接下来便是对server端的深入处理，使得server端能够一直不断的接受处理连接请求。