共计 4037 个字符，预计需要花费 11 分钟才能阅读完成。
今天丸趣 TV 小编给大家分享一下 linux socket 怎么实现使用线程独立收发消息的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家参考一下，希望大家阅读完这篇文章后有所收获，下面我们一起来了解一下吧。
代码实现
1、服务器端
/*tcpserver.c 2011.9.1 by yyg*/
#include stdio.h
#include stdlib.h
#include errno.h
#include string.h
#include sys/types.h
#include netinet/in.h
#include sys/socket.h
#include sys/wait.h
#include pthread.h
#define MYPORT 3490 // 定义端口
#define BACKLOG 10
#define MAXDATASIZE 1024
int sockfd,new_fd;
pthread_t accthread,recthread;
void recmessage(void){ // 接收客户端信息函数
while(1){
int numbytes;
char buf[MAXDATASIZE];
if((numbytes = recv(new_fd,buf,MAXDATASIZE,0))==-1){
perror( recv
exit(1);
}
buf[numbytes]= \0
if(strcmp(buf, exit)==0){ // 若收到的是 exit 字符，则代表退出通信
printf( Client is closed\n
close(new_fd);
close(sockfd);
exit(1);
}
printf(client:%s\n ,buf);
}/*while*/
void acceptconnect(void){ // 接受客户端连接请求函数
struct sockaddr_in their_addr;
int sin_size;
sin_size = sizeof(struct sockaddr_in);
if((new_fd = accept(sockfd,(struct sockaddr *) their_addr, sin_size))==-1){
perror( accept
exit(1);
}
printf(server:got connection from %s\n ,inet_ntoa(their_addr.sin_addr));
/* 创建子线程，用于接收信息 */
if((pthread_create( recthread,NULL,(void*)recmessage,NULL)) != 0){
printf( create thread error!\r\n
exit(1);
}
int main(void){
struct sockaddr_in my_addr;
/* 创建套接字 */
if((sockfd = socket(AF_INET,SOCK_STREAM,0)) == -1){
perror( socket
exit(1);
}
/* 初始化 sockaddr_in 结构体相关参数 */
my_addr.sin_family = AF_INET;
my_addr.sin_port = htons(MYPORT);
my_addr.sin_addr.s_addr = INADDR_ANY;
bzero((my_addr.sin_zero),8);
/* 绑定端口与套接字 */
if(bind(sockfd,(struct sockaddr*) my_addr,sizeof(struct sockaddr)) == -1){
perror( bind
exit(1);
}
/* 监听客户端套接字 */
if(listen(sockfd,BACKLOG)== -1){
perror( listen
exit(1);
}
printf( listening...\n
/* 创建子线程，用于接收信息 */
if((pthread_create( accthread,NULL,(void*)acceptconnect,NULL))!=0){
printf( create thread error!\n
exit(1);
}
while(1){ char msg[MAXDATASIZE];
scanf(%s ,msg);
if(send(new_fd,msg,strlen(msg),0) == -1){ // 发送信息，与客户端交流
perror( send
exit(1);
}
if(strcmp(msg, exit) ==0){
printf( byebye\n
close(new_fd);
close(sockfd);
exit(1);
}
}/*while*/
return 0;
}/*main*/2. 客户端
/*tcpclient.c 2010.9.1 by yyg*/
#include stdio.h
#include stdlib.h
#include errno.h
#include string.h
#include sys/types.h
#include netinet/in.h
#include sys/socket.h
#include sys/wait.h
#include pthread.h
#include netdb.h
#define PORT 3490
#define BACKLOG 10
#define MAXDATASIZE 1024
int sockfd;
pthread_t recthread;
/* 接收信息函数 */
void recmessage(void){ while(1){
int numbytes;
char buf[MAXDATASIZE];
if((numbytes = recv(sockfd,buf,MAXDATASIZE,0))==-1){
perror( recv
exit(1);
}
buf[numbytes]= \0
if(strcmp(buf, exit)==0){
printf( Server is closed\n
close(sockfd);
exit(1);
}
printf(Server:%s\n ,buf);
}/*while*/
int main(int argc,char *argv[]){
struct hostent *he;
struct sockaddr_in their_addr;
/* 客户端输入方式:./client 172.31.100.236, 若无输入后面 IP 地址，会提示错误 */
if(argc != 2){
fprintf(stderr, usage:client hostname\n
exit(1);
}
/* 获取主机 IP 地址 */
if((he = gethostbyname(argv[1])) == NULL){
herror( gethostbyname
exit(1);
}
/* 创建套接字 */
if((sockfd = socket(AF_INET,SOCK_STREAM,0)) == -1){
perror( socket
exit(1);
}
/* 初始化 sockaddr_in 结构体 */
their_addr.sin_family = AF_INET;
their_addr.sin_port = htons(PORT);
their_addr.sin_addr = *((struct in_addr *)he- h_addr);
bzero((their_addr.sin_zero),8);
/* 向服务器发送连接请求 */
if(connect(sockfd,(struct sockaddr *) their_addr,sizeof(struct sockaddr)) == -1){
perror( connect
exit(1);
}
/* 创建子线程，用于接收信息 */
if((pthread_create( recthread,NULL,(void*)recmessage,NULL))!= 0){
printf( create thread error!\r\n
exit(1);
}
/* 发送信息。接收发送信息用的是同一端口，都 是 sockfd*/
while(1){ char msg[MAXDATASIZE];
scanf(%s ,msg);
if(send(sockfd,msg,strlen(msg),0) == -1){
perror( send
exit(1);
}
if(strcmp(msg, exit) ==0){
printf( byebye\n
close(sockfd);
exit(1);
}
}/*while*/
return 0;
}运行结果：
终端 1：
[root@localhost net]# ./tcpserver
server:got connection from 172.31.100.236
Hello,World!
client:hello
client:xiaolian
client:iou
byebye终端 2：
[root@localhost net]# ./tcpclient 172.31.100.236
Server:Hello,World!
hello
xiaolian iou
Server:ok
Server is closed以上就是“linux socket 怎么实现使用线程独立收发消息”这篇文章的所有内容，感谢各位的阅读！相信大家阅读完这篇文章都有很大的收获，丸趣 TV 小编每天都会为大家更新不同的知识，如果还想学习更多的知识，请关注丸趣 TV 行业资讯频道。
正文完
