在线网页设计网站,网站建设哪个公司好,推广方式,医疗网站建设效果概述
下面是一个通用的server端程序源码#xff0c;用于实现两个client之间的通信。
功能
1、接收user的命令cmd消息#xff0c;并将cmd消息发送到dev#xff1b;
2、接收dev的应答ack消息#xff0c;并将ack消息发送到user#xff1b;
架构实现
通过6个线程实现。 …概述
下面是一个通用的server端程序源码用于实现两个client之间的通信。
功能
1、接收user的命令cmd消息并将cmd消息发送到dev
2、接收dev的应答ack消息并将ack消息发送到user
架构实现
通过6个线程实现。
thread_init_user
用于创建user socket并创建接收user cmd的线程recv_cmd_from_user 和将ack发送给user的线程send_ack_to_user
recv_cmd_from_user
用于接收user客户端的cmd并激活send_ack_to_user线程
send_ack_to_user
将user cmd发送到设备
thread_init_dev
用于创建dev socket并创建将cmd发送给dev的线程send_cmd_to_dev 和接收dev ack的线程recv_ack_from_dev
send_cmd_to_dev
用于将user客户端的cmd 发送到dev客户端
recv_ack_from_dev
用于接收dev客户端的ack并激活send_ack_to_user
注意要点
客户端断开后server端相应的线程会收到长度为0的信息收到此消息后要退出这个线程同时通知这个客户端的发送线程退出。
源码
#include stdio.h
#include stdlib.h
#include unistd.h
#include sys/stat.h
#include fcntl.h
#include termios.h
#include pthread.h
#include termios.h
#include string.h
#include dlfcn.h
#include sys/types.h
#include sys/time.h
#include dirent.h
#include signal.h
#include net/if.h
#include sys/ioctl.h
#include sys/socket.h
#include netinet/in.h
#include arpa/inet.h
#include errno.h
#include netinet/tcp.h
#include string.h
#include stdbool.h
#include linux/rtnetlink.h
#include netinet/ether.h
#include semaphore.h#define FRAME_LEN_MAX 256static sem_t sem_recv_user;
static sem_t sem_send_dev;
static sem_t sem_recv_ack_start;
static sem_t sem_recv_ack_end;static unsigned char g_cmd_frame[FRAME_LEN_MAX];
static int g_cmd_frame_len;
static unsigned char g_ack_frame[FRAME_LEN_MAX];
static int g_ack_frame_len;static bool g_user_thread_exit;
static bool g_dev_thread_exit;static void *recv_cmd_from_user(void *arg)
{int fd 0;int ret 0;if (!arg) {printf([%s] arg is NULL!\n, __FUNCTION__);return NULL;}fd *(int *)arg;if (fd 0) {printf([%s] invailed arg!\n, __FUNCTION__);return NULL;}printf([%s] thread run\n, __FUNCTION__);while (1) {ret recv(fd, g_cmd_frame, FRAME_LEN_MAX, 0);printf([%s] recv ret:%d!\n, __FUNCTION__, ret);if(ret 0) {//当用户客户端断开时会走这里本进程退出同时发送信号量通知另个一线程退出g_user_thread_exit 1;sem_post(sem_recv_ack_start);break;}g_cmd_frame_len ret;sem_post(sem_recv_user);}close(fd);pthread_exit(NULL);
}static void *send_cmd_to_dev(void *arg)
{int fd 0;int ret 0;if (!arg) {printf([%s] arg is NULL!\n, __FUNCTION__);return NULL;}fd *(int *)arg;if (fd 0) {printf([%s] invailed arg!\n, __FUNCTION__);return NULL;}printf([%s] thread run\n, __FUNCTION__);while (1) {sem_wait(sem_recv_user);if(g_dev_thread_exit) {break;}ret send(fd, g_cmd_frame, g_cmd_frame_len, 0);printf([%s] send to client:%d ret:%d!\n, __FUNCTION__, fd, ret);if(ret 0) {break;}sem_post(sem_send_dev);}close(fd);pthread_exit(NULL);
}static void *recv_ack_from_dev(void *arg)
{int fd 0;int ret 0;if (!arg) {printf([%s] arg is NULL!\n, __FUNCTION__);return NULL;}fd *(int *)arg;if (fd 0) {printf([%s] invailed arg!\n, __FUNCTION__);return NULL;}printf([%s] thread run\n, __FUNCTION__);while (1) {sem_wait(sem_send_dev);//dev客户端主动发送命令会被阻塞直到user客户端发送命令sem_post(sem_recv_ack_start);ret recv(fd, g_ack_frame, FRAME_LEN_MAX);printf([%s] recv ret:%d!\n, __FUNCTION__, ret);if(ret 0) {g_dev_thread_exit 1;sem_post(sem_recv_user);break;}g_ack_frame_len ret;sem_post(sem_recv_ack_end);}close(fd);pthread_exit(NULL);
}static void *send_ack_to_user(void *arg)
{int fd 0;int ret 0;if (!arg) {printf([%s] arg is NULL!\n, __FUNCTION__);return NULL;}fd *(int *)arg;if (fd 0) {printf([%s] invailed arg!\n, __FUNCTION__);return NULL;}printf([%s] thread run\n, __FUNCTION__);while (1) {struct timespec ts;sem_wait(sem_recv_ack_start);if(g_user_thread_exit) {break;}
#if 0//对应答时间有要求可以打开这里if (clock_gettime(CLOCK_REALTIME, ts) -1)printf([%s] ERROR:get current time failed\n,__FUNCTION__);ts.tv_nsec 10 * MS_TO_NS;ret sem_timedwait(sem_recv_dev_end, ts);
#elsesem_wait(sem_recv_dev_end);
#endifret send(fd, g_ack_frame, g_ack_frame_len);printf([%s] send to client:%d ret:%d!\n, __FUNCTION__, fd, ret);if (ret 0) {break;}}close(fd);pthread_exit(NULL);
}void *thread_init_user(void *arg)
{struct sockaddr_in server_addr;struct sockaddr_in client_addr;pthread_t tid_rx;pthread_t tid_tx;int server_fd 0;int client_fd 0;int ret 0;int addr_size sizeof(client_addr);int port *(int *)arg;server_fd socket(AF_INET, SOCK_STREAM, 0);if(server_fd 0){printf([%s] socket failed! port:%d\n, __FUNCTION__, port);return NULL;}printf([%s] socket sucess! server_fd:%d, port:%d\n, __FUNCTION__,server_fd, port);bzero( server_addr, sizeof(struct sockaddr_in) );server_addr.sin_family AF_INET;server_addr.sin_addr.s_addr inet_addr((const char*)IP_ADDR_DFLT);server_addr.sin_port htons(port);if(bind(server_fd, (struct sockaddr *)server_addr, sizeof(server_addr)) 0) {printf([%s] bind failed!\n, __FUNCTION__);return NULL;}printf([%s] bind sucess! server_fd:%d\n, __FUNCTION__,server_fd);if (listen(server_fd, 10) -1) {printf([%s] listen failed!\n, __FUNCTION__);return NULL;}printf([%s] listen sucess! server_fd:%d\n\n, __FUNCTION__,server_fd);set_socket_alive(server_fd);while (server_fd ! -1) {client_fd accept(server_fd, (struct sockaddr *)client_addr, addr_size);if (client_fd 0) {printf([%s] accept failed: %d!\n, __FUNCTION__, client_fd);sleep(1);continue;}g_user_thread_exit 0;printf([%s] client: %d connected!\n, __FUNCTION__, client_fd);ret pthread_create(tid_rx, NULL, recv_cmd_from_user, client_fd);if(ret ! 0) {continue;}pthread_detach(tid_rx);ret pthread_create(tid_tx, NULL, send_ack_to_user, client_fd);if(ret ! 0) {continue;}pthread_detach(tid_tx);}return NULL;
}void *thread_init_dev(void *arg)
{struct sockaddr_in server_addr;struct sockaddr_in client_addr;pthread_t tid_rx;pthread_t tid_tx;int server_fd 0;int client_fd 0;int ret 0;int addr_size sizeof(client_addr);int port *(int *)arg;server_fd socket(AF_INET, SOCK_STREAM, 0);if(server_fd 0){printf([%s] socket failed!\n, __FUNCTION__);return NULL;}printf([%s] socket sucess! server_fd:%d, port:%d\n, __FUNCTION__,server_fd, port);bzero( server_addr, sizeof(struct sockaddr_in) );server_addr.sin_family AF_INET;server_addr.sin_addr.s_addr inet_addr((const char*)IP_ADDR_DFLT);server_addr.sin_port htons(port);if(bind(server_fd, (struct sockaddr *)server_addr, sizeof(server_addr)) 0) {printf([%s] bind failed!\n, __FUNCTION__);return NULL;}printf([%s] bind sucess! server_fd:%d\n, __FUNCTION__,server_fd);if (listen(server_fd, 10) -1) {printf([%s] listen failed!\n, __FUNCTION__);return NULL;}printf([%s] listen sucess! server_fd:%d\n\n, __FUNCTION__,server_fd);set_socket_alive(server_fd);while (server_fd ! -1) {client_fd accept(server_fd, (struct sockaddr *)client_addr, addr_size);if (client_fd 0) {printf([%s] accept failed: %d!\n, __FUNCTION__, client_fd);sleep(1);continue;}g_dev_thread_exit 0;printf([%s] client: %d connected!\n, __FUNCTION__, client_fd);ret pthread_create(tid_rx, NULL, recv_ack_from_dev, client_fd);if(ret ! 0) {continue;}pthread_detach(tid_rx);ret pthread_create(tid_tx, NULL, send_cmd_to_dev, client_fd);if(ret ! 0) {continue;}pthread_detach(tid_tx);}return NULL;
}int main(int argc, char *argv[])
{int user_port PORT_USER;int dev_port PORT_DEV;pthread_t thread_user;pthread_t thread_dev;pthread_attr_t attr;if(argc 2)user_port auto_convert_0x(argv[1]);if(argc 3)dev_port auto_convert_0x(argv[2]);printf([%s]user_port:%d, dev_port:%d\n, __FUNCTION__, user_port, dev_port);sem_init(sem_recv_user,0,0);sem_init(sem_send_dev,0,0);sem_init(sem_recv_ack_start,0,0);sem_init(sem_recv_ack_end,0,0);pthread_attr_init (attr);pthread_attr_setdetachstate(attr, PTHREAD_CREATE_DETACHED);if (0 ! pthread_create(thread_user, attr, thread_init_user, (void *)user_port)) {printf([%s] thread_user init failed\n, __FUNCTION__);return 0;}sleep(1);if (0 ! pthread_create(thread_dev, attr, thread_init_dev, (void *)dev_port)) {printf([%s] thread_dev init failed\n, __FUNCTION__);return 0;}while(1) {sleep(UINT32_MAX);}return 0;
} 参考文档
linux下的Socket网络编程教程_linux socket 编程示例-CSDN博客
