1. 概述:
该demo主要实现了linux下通过select(tcp)方式的socket并发通讯,相关接口介绍可以参考<<UNIX环境高级编程>>
2. 场景(服务端(一)<----(多)客户端):
1) 服务端:
输入:服务端监听的port;
接收到客户端发送的消息,打印到终端,并且回复客户端"ok"
2) 客户端:
输入:客户端的port,以及服务端ip和port;
输入消息内容,将消息发送给服务端,阻塞直到接收到服务端的返回信息,并打印到终端(超时未接收到时,报错);
当输入消息内容为"exit"时,选择退出客户端进程
3. 测试:
SELECT(TCP) 服务端
客户端1
客户端2
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <signal.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include "lpm.h"
void signal_func() {
printf(RED BLINK"Server Close\n\n"NONE);
}
int main(int argc, char **argv){
int ret;
int client_fd = -1;
char client_port[8];
char server_ip[32];
char server_port[8];
char buf[MAX_BUF];
printf(RED BLINK"SELECT 客户端\n"NONE);
printf("请输入客户端 port\t");
scanf("%s", client_port);
printf("请输入服务端 ip \t");
scanf("%s", server_ip);
printf("请输入服务端 port\t");
scanf("%s", server_port);
printf("\n");
if(SIG_ERR == signal(SIGPIPE,signal_func)){
perror("signal:");
return -1;
}
client_fd = socket(AF_INET, SOCK_STREAM, 0);
if(client_fd < 0){
perror("socket:");
return -1;
}
int opt = 1;
ret = setsockopt(client_fd, SOL_SOCKET, SO_REUSEADDR, (void *)&opt, sizeof(opt));
if(ret < 0){
perror("setsockopt");
close(client_fd);
return -1;
}
struct timeval tv;
tv.tv_sec = RECV_TIME_OUT;
tv.tv_usec = 0;
ret = setsockopt(client_fd, SOL_SOCKET, SO_RCVTIMEO, (void *)&tv, sizeof(tv));
if(ret < 0){
perror("setsockopt");
close(client_fd);
return -1;
}
struct sockaddr_in client_addr;
memset(&client_addr, 0x0, sizeof(struct sockaddr_in));
client_addr.sin_family = AF_INET;
client_addr.sin_port = htons(atoi(client_port));
client_addr.sin_addr.s_addr = htonl(INADDR_ANY);
ret = bind(client_fd, (struct sockaddr*)&client_addr, sizeof(client_addr));
if(ret < 0){
perror("bind:");
close(client_fd);
return -1;
}
struct sockaddr_in server_addr;
memset(&server_addr, 0x0, sizeof(struct sockaddr_in));
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(atoi(server_port));
inet_pton(AF_INET, server_ip, (void *)&(server_addr.sin_addr.s_addr));
ret = connect(client_fd, (struct sockaddr*)&server_addr, sizeof(server_addr));
if(ret < 0){
perror("connect:");
close(client_fd);
return -1;
}
memset(buf, 0x0, sizeof(buf));
ret = recv(client_fd, buf, sizeof(buf), 0);
if(ret > 0){
printf("%s\n", buf);
printf("\n");
}
else if(ret == 0){
printf(RED BLINK"Server Close\n\n"NONE);
close(client_fd);
return -1;
}
else if(ret < 0){
perror("recv:");
close(client_fd);
return -1;
}
while(1){
memset(buf, 0x0, sizeof(buf));
printf("请输入消息\t");
scanf("%s", buf);
ret = send(client_fd, buf, strlen(buf), 0);
if(ret < 0){
perror("send:");
continue;
}
if(strlen(buf) > 0 && strncmp(buf, EXIT, strlen(buf)) == 0){
break;
}
memset(buf, 0x0, sizeof(buf));
ret = recv(client_fd, buf, sizeof(buf), 0);
if(ret > 0){
printf("%s\n", buf);
printf("\n");
}
else if(ret == 0){
printf(RED BLINK"Server Close\n\n"NONE);
break;
}
else if(ret < 0){
perror("recv:");
continue;
}
}
shutdown(client_fd, SHUT_RDWR);
close(client_fd);
return 0;
}
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <signal.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include "lpm.h"
void signal_func() {
printf(RED BLINK"Client Close\n\n"NONE);
}
int main(int argc, char **argv){
int ret;
int i = 0;
int server_fd = -1;
char server_port[8];
char buf[MAX_BUF];
printf(RED BLINK"SELECT 服务端\n"NONE);
printf("请输入服务端 port\t");
scanf("%s", server_port);
printf("\n");
if(SIG_ERR == signal(SIGPIPE,signal_func)){
perror("signal:");
return -1;
}
server_fd = socket(AF_INET, SOCK_STREAM, 0);
if(server_fd < 0){
perror("socket:");
return -1;
}
int opt = 1;
ret = setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR, (void *)&opt, sizeof(opt));
if(ret < 0){
perror("setsockopt");
close(server_fd);
return -1;
}
struct sockaddr_in server_addr;
memset(&server_addr, 0x0, sizeof(struct sockaddr_in));
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(atoi(server_port));
server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
ret = bind(server_fd, (struct sockaddr*)&server_addr, sizeof(server_addr));
if(ret < 0){
perror("bind:");
close(server_fd);
return -1;
}
ret = listen(server_fd, MAX_LISTEN);
if(ret < 0){
perror("listen:");
close(server_fd);
return -1;
}
char IP[32];
int addrLen = sizeof(struct sockaddr);
int client_fd[MAX_ACCEPT];
struct sockaddr_in client_addr[MAX_ACCEPT];
for(i = 0; i < MAX_ACCEPT; i ++){
client_fd[i] = -1;
memset(&client_addr[i], 0x0, sizeof(struct sockaddr_in));
}
int OverClient_fd = -1;
struct sockaddr_in OverClient_addr;
struct timeval t;
fd_set fd_set;
int max_fd = server_fd;
while(1){
t.tv_sec = 60;
t.tv_usec = 0;
FD_ZERO(&fd_set);
FD_SET(server_fd, &fd_set);
for(i = 0; i < MAX_ACCEPT; i ++){
if(client_fd[i] > 0){
FD_SET(client_fd[i], &fd_set);
}
}
switch(select(max_fd+1, &fd_set, NULL, NULL, &t))
{
case -1:
perror("select:");
break;
case 0:
printf("time out!\n");
break;
default:
{
if(FD_ISSET(server_fd, &fd_set)){
for(i = 0; i <= MAX_ACCEPT; i ++){
if(client_fd[i] < 0 && i < MAX_ACCEPT){
memset(&client_addr[i], 0x0, sizeof(struct sockaddr_in));
client_fd[i] = accept(server_fd, (struct sockaddr *)(&client_addr[i]), (socklen_t *)&addrLen);
if(client_fd[i] < 0){
perror("accept:");
break;
}
memset(IP, 0x0, sizeof(IP));
inet_ntop(AF_INET, (void *)&client_addr[i].sin_addr.s_addr, IP, sizeof(IP));
printf("客户端 IP \t%s\n", IP);
printf("客户端 port\t%d\n", ntohs(client_addr[i].sin_port));
printf("\n");
ret = send(client_fd[i], OK, strlen(OK), 0);
if(ret < 0){
perror("send:");
close(client_fd[i]);
client_fd[i] = -1;
break;
}
FD_SET(client_fd[i], &fd_set);
max_fd = max_fd > client_fd[i] ? max_fd : client_fd[i];
}
else if(i == MAX_ACCEPT){
if(OverClient_fd < 0){
memset(&OverClient_addr, 0x0, sizeof(struct sockaddr_in));
OverClient_fd = accept(server_fd, (struct sockaddr *)(&OverClient_addr), (socklen_t *)&addrLen);
if(OverClient_fd < 0){
perror("accept:");
break;
}
memset(IP, 0x0, sizeof(IP));
inet_ntop(AF_INET, (void *)&OverClient_addr.sin_addr.s_addr, IP, sizeof(IP));
printf("客户端 IP \t%s\n", IP);
printf("客户端 port\t%d\n", ntohs(OverClient_addr.sin_port));
printf(RED BLINK"Unable to accept\n"NONE);
printf("\n");
ret = send(OverClient_fd, ERROR, strlen(ERROR), 0);
if(ret < 0){
perror("send:");
}
close(OverClient_fd);
OverClient_fd = -1;
}
}
}
}
else {
for(i = 0; i < MAX_ACCEPT; i ++){
if(FD_ISSET(client_fd[i], &fd_set)){
memset(buf, 0x0, sizeof(buf));
memset(IP, 0x0, sizeof(IP));
inet_ntop(AF_INET, (void *)&client_addr[i].sin_addr.s_addr, IP, sizeof(IP));
printf("客户端 IP \t%s\n", IP);
printf("客户端 port\t%d\n", ntohs(client_addr[i].sin_port));
ret = recv(client_fd[i], buf, sizeof(buf), 0);
if(ret > 0){
printf("消息 \t%s\n", buf);
printf("\n");
}
else if(ret == 0){
printf(RED BLINK"Client Close\n\n"NONE);
}
else if(ret < 0){
perror("recv:");
break;
}
if(ret == 0 || (strlen(buf) > 0 && strncmp(buf, EXIT, strlen(buf)) == 0)){
FD_CLR(client_fd[i], &fd_set);
close(client_fd[i]);
client_fd[i] = -1;
break;
}
ret = send(client_fd[i], OK, strlen(OK), 0);
if(ret < 0){
perror("send:");
break;
}
}
}
}
}
break;
}
}
shutdown(server_fd, SHUT_RDWR);
for(i = 0; i < MAX_ACCEPT; i ++){
if(client_fd[i] > 0){
close(client_fd[i]);
}
}
close(server_fd);
return 0;
}
#ifndef _LPM_H_
#define _LPM_H_
#define NONE "\e[0m"
#define BLACK "\e[0;30m"
#define L_BLACK "\e[1;30m"
#define RED "\e[0;31m"
#define L_RED "\e[1;31m"
#define GREEN "\e[0;32m"
#define L_GREEN "\e[1;32m"
#define BROWN "\e[0;33m"
#define YELLOW "\e[1;33m"
#define BLUE "\e[0;34m"
#define L_BLUE "\e[1;34m"
#define PURPLE "\e[0;35m"
#define L_PURPLE "\e[1;35m"
#define CYAN "\e[0;36m"
#define L_CYAN "\e[1;36m"
#define GRAY "\e[0;37m"
#define WHITE "\e[1;37m"
#define BOLD "\e[1m"
#define UNDERLINE "\e[4m"
#define BLINK "\e[5m"
#define REVERSE "\e[7m"
#define HIDE "\e[8m"
#define CLEAR "\e[2J"
#define CLRLINE "\r\e[K"
#define MAX_BUF 64
#define RECV_TIME_OUT 3
#define MAX_LISTEN 1
#define MAX_ACCEPT 2
#define OK "ok"
#define EXIT "exit"
#define ERROR "error"
#define LOG() printf("[%s %s] %s: %s: %d\n", __DATE__, __TIME__, __FILE__, __func__, __LINE__)
#endif
#Makefile
CC := gcc
INCLUDE = -I /home/demo/include/
all:
$(CC) demo_select_server.c $(INCLUDE) -o demo_select_server -Wall -Werror
$(CC) demo_select_client.c $(INCLUDE) -o demo_select_client -Wall -Werror
clean:
rm demo_select_server demo_select_client
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)