linux下多线程控制服务器与客户端

include”client_slave.h”

void *modbus_server_client_thread()

{

char buf[BUFFER_SIZE];

int client_sockfd;

int len;

struct sockaddr_in address;// 服务器端网络地址结构体

int result;

client_sockfd = socket(AF_INET, SOCK_STREAM, 0);// 建立客户端socket

address.sin_family = AF_INET;

address.sin_addr.s_addr = inet_addr(“127.0.0.1”);

address.sin_port = htons(12000);

len = sizeof(address);

// 与远程服务器建立连接

result = connect(client_sockfd, (struct sockaddr *)&address, len);

if(result<0)

{

perror(“connect failed”);

exit(EXIT_FAILURE);

}

printf(“Please input the message:”);

scanf(“%s”,buf);

send(client_sockfd,buf,BUFFER_SIZE,0);

recv(client_sockfd,buf,BUFFER_SIZE,0);

printf(“receive data from server: %s/n”,buf);

close(client_sockfd);

return 0;

}

void *modbus_server_slave_thread()

{

char buf[BUFFER_SIZE];

int server_sockfd, client_sockfd;

int sin_size=sizeof(struct sockaddr_in);

struct sockaddr_in server_address;

struct sockaddr_in client_address;

memset(&server_address,0,sizeof(server_address));

server_address.sin_family = AF_INET;

server_address.sin_addr.s_addr = INADDR_ANY;

server_address.sin_port = htons(12000);

// 建立服务器端socket

if((server_sockfd = socket(AF_INET, SOCK_STREAM, 0))<0)

{

perror(“server_sockfd creation failed”);

exit(EXIT_FAILURE);

}

// 设置套接字选项避免地址使用错误

int on=1;

if((setsockopt(server_sockfd,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on)))<0)

{

perror(“setsockopt failed”);

exit(EXIT_FAILURE);

}

// 将套接字绑定到服务器的网络地址上

if((bind(server_sockfd,(struct sockaddr *)&server_address,sizeof(struct sockaddr)))<0)

{

perror(“server socket bind failed”);

exit(EXIT_FAILURE);

}

// 建立监听队列

listen(server_sockfd,5);

// 等待客户端连接请求到达

// usleep(5000);

client_sockfd=accept(server_sockfd,(struct sockaddr )&client_address,(socklen_t)&sin_size);

if(client_sockfd<0)

{

perror(“accept client socket failed”);

exit(EXIT_FAILURE);

}

// 接收客户端数据

if(recv(client_sockfd,buf,BUFFER_SIZE,0)<0)

{

perror(“recv client data failed”);

exit(EXIT_FAILURE);

}

printf(“receive from client:%s/n”,buf);

// 发送数据到客户端

if(send(client_sockfd,buf,BUFFER_SIZE,0)<0)

{

perror(“send failed”);

exit(EXIT_FAILURE);

}

close(client_sockfd);

close(server_sockfd);
exit(EXIT_SUCCESS);

}

void main()

{

int ret;

pthread_t modbus_client_thread,modbus_slave_thread;

pthread_create(&modbus_slave_thread,NULL,modbus_server_slave_thread,NULL);

sleep(1);

pthread_create(&modbus_client_thread,NULL,modbus_server_client_thread,NULL);

/等待线程结束/

pthread_join(modbus_slave_thread,NULL);

pthread_join(modbus_client_thread,NULL);//pthread_join会阻塞主线程，等待子线程结束。

return;

}

#include <sys/types.h>
#include <sys/socket.h>
#include <linux/in.h>
#include <linux/un.h>
#include <string.h>
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <malloc.h>
#include <errno.h>
#include <unistd.h>
#include <unistd.h>
#include <signal.h>
#include <sys/ioctl.h>
#include <pthread.h>
#include <sys/time.h>
#include <sys/select.h>
#include <fcntl.h>
#include <unistd.h>
#define BUFFER_SIZE 40