利用多线程实现linux下C语言的聊天室程序:

转载:http://www.360doc.com/content/16/0421/11/478627_552531090.shtml

利用多线程实现linux下C语言的聊天室程序:

客户端代码:

threadsend线程负责客户端消息的发送;

threadrecv线程负责客户端接受服务器端的消息。

[html] view plain copy
  1. #include <stdlib.h>  
  2. #include <stdio.h>  
  3. #include <errno.h>  
  4. #include <string.h>  
  5. #include <unistd.h>  
  6. #include <netdb.h>  
  7. #include <sys/socket.h>  
  8. #include <netinet/in.h>  
  9. #include <sys/types.h>  
  10. #include <arpa/inet.h>  
  11. #include <pthread.h>  
  12.   
  13. #define MAXLINE 100;  
  14. void *threadsend(void *vargp);  
  15. void *threadrecv(void *vargp);  
  16.   
  17. int main()  
  18. {  
  19.   
  20. int *clientfdp;  
  21. clientfdp = (int *)malloc(sizeof(int));  
  22. *clientfdp = socket(AF_INET,SOCK_STREAM,0);  
  23. struct sockaddr_in serveraddr;  
  24. struct hostent *hp;  
  25. bzero((char *)&serveraddr,sizeof(serveraddr));  
  26. serveraddr.sin_family = AF_INET;  
  27. serveraddr.sin_port = htons(15636);  
  28. serveraddr.sin_addr.s_addr = inet_addr("127.0.0.1");  
  29. if(connect(*clientfdp,(struct sockaddr *)&serveraddr,sizeof(serveraddr)) < 0){  
  30.         printf("connect error\n");  
  31.         exit(1);  
  32. }  
  33.   
  34. pthread_t tid1,tid2;  
  35. printf("connected\n");  
  36. while(1){  
  37. pthread_create(&tid1,NULL,threadsend,clientfdp);  
  38.   
  39. pthread_create(&tid2,NULL,threadrecv,clientfdp);  
  40. }  
  41.   
  42. return EXIT_SUCCESS;  
  43. }  
  44.   
  45. void *threadsend(void * vargp)  
  46. {  
  47. //pthread_t tid2;  
  48. int connfd = *((int *)vargp);  
  49.   
  50. int idata;  
  51. char temp[100];  
  52. while(1){  
  53. //printf("me: \n ");  
  54. fgets(temp,100,stdin);  
  55. send(connfd,temp,100,0);  
  56. printf("          client send OK\n");  
  57.   
  58. }  
  59.   
  60.   
  61. printf("client send\n");  
  62. return NULL;  
  63. }  
  64.   
  65.   
  66. void *threadrecv(void *vargp)  
  67. {  
  68. char temp[100];  
  69. int connfd = *((int *)vargp);  
  70. while(1){  
  71. int idata = 0;  
  72. idata = recv(connfd,temp,100,0);  
  73. if(idata > 0){  
  74. printf("server :\n%s\n",temp);  
  75. }  
  76. }  
  77.   
  78.   
  79. return NULL;  
  80. }  

服务器端代码:

threadsend负责服务器端发送信息;

threadrecv负责接受客户端信息。

[html] view plain copy
  1. #include <stdlib.h>  
  2. #include <stdio.h>  
  3. #include <errno.h>  
  4. #include <string.h>  
  5. #include <unistd.h>  
  6. #include <netdb.h>  
  7. #include <sys/socket.h>  
  8. #include <netinet/in.h>  
  9. #include <sys/types.h>  
  10. #include <arpa/inet.h>  
  11. #include <pthread.h>  
  12. #define PORT 15636  
  13. void *thread(void *vargp);  
  14. void *threadsend(void *vargp);  
  15. void *threadrecv(void *vargp);  
  16.   
  17. int main()  
  18. {  
  19.   
  20. int listenfd = socket(AF_INET, SOCK_STREAM,0);  
  21. if(listenfd < 0){  
  22.         perror("socket");  
  23.         exit(1);  
  24. }  
  25.   
  26. struct hostent *hp;  
  27. struct sockaddr_in serveraddr;  
  28. bzero((char *)&serveraddr,sizeof(serveraddr));  
  29. serveraddr.sin_family = AF_INET;  
  30. serveraddr.sin_addr.s_addr = htonl(INADDR_ANY);  
  31. serveraddr.sin_port = htons(PORT);  
  32.   
  33. if(bind(listenfd,(struct sockaddr *)&serveraddr,sizeof(serveraddr)) < 0){  
  34.         perror("connect");  
  35.         exit(1);  
  36. }  
  37.   
  38. if(listen(listenfd,1024) < 0){  
  39.         perror("listen error");  
  40.         exit(1);  
  41. }  
  42.   
  43. //char temp[100];  
  44. struct sockaddr_in clientaddr;  
  45. int clientlen, *connfdp;  
  46. clientlen = sizeof(clientaddr);  
  47. while(1){  
  48. connfdp = (int *)malloc(sizeof(int));  
  49. *connfdp = accept(listenfd,(struct sockaddr *)&clientaddr, &clientlen);  
  50. pthread_t tid;  
  51. printf("Accepted!\n");  
  52. pthread_create(&tid,NULL,thread,connfdp);  
  53. }  
  54. EXIT_SUCCESS;  
  55. }  
  56.   
  57. void *thread(void *vargp)  
  58. {  
  59.   
  60. pthread_t tid1,tid2;  
  61. int connfd = *((int *)vargp);  
  62. int idata;  
  63. char temp[100];  
  64. pthread_create(&tid1,NULL,threadsend,vargp);  
  65. pthread_create(&tid2,NULL,threadrecv,vargp);  
  66. return NULL;  
  67. }  
  68.   
  69. void *threadsend(void * vargp)  
  70. {  
  71.   
  72. int connfd = *((int *)vargp);  
  73.   
  74. int idata;  
  75. char temp[100];  
  76. while(1){  
  77. //printf("server input:  ");  
  78. fgets(temp,100,stdin);  
  79. send(connfd,temp,100,0);  
  80. printf("        server send OK\n");  
  81. }  
  82. return NULL;  
  83. }  
  84.   
  85. void *threadrecv(void *vargp)  
  86. {  
  87. char temp[100];  
  88. int connfd = *((int *)vargp);  
  89. while(1){  
  90. int idata = 0;  
  91. idata = recv(connfd,temp,100,0);  
  92. if(idata > 0){  
  93. printf("client :\n%s\n",temp);  
  94. }  
  95. }  
  96. return NULL;  
  97. }  

问题:

linux下编译多线程代码时,shell提示找不到 pthread_create函数,原因是 pthread.h不是linux系统默认加载的库文件,应该使用类似如下gcc命令进行编译:

gcc echoserver.c -lpthread -o echoserver

只要注意 -lpthread参数就可以了。


运行结果:

客户端:

[html] view plain copy
  1. [root@localhost unixIO]# ./echoclient  
  2. connected  
  3. hello!  
  4.           client send OK  
  5. goodmorning  
  6.           client send OK  
  7. server :  
  8. goodmorning too!  
  9.   
  10. server :  
  11. how r u?  
  12.   
  13. fine  
  14.           client send OK  

服务器端:


[html] view plain copy
  1. [root@localhost unixIO]# ./echoserver  
  2. Accepted!  
  3. client :  
  4. hello!  
  5.   
  6. client :  
  7. goodmorning  
  8.   
  9. goodmorning too!  
  10.         server send OK  
  11. how r u?  
  12.         server send OK  
  13. client :  
  14. fine  

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/384404.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Linux系统编程(七)消息队列

Linux系统编程&#xff08;七&#xff09;消息队列一、什么是消息队列二、消息队列内部原理三、实现消息队列的收发1.发送消息队列2.接收消息队列四、消息队列与命名管道的比较一、什么是消息队列 消息队列提供了一种从一个进程向另一个进程发送一个数据块的方法。每个数据块都…

基于Linux的SOCKET编程之TCP半双工Client-Server聊天程序

转自&#xff1a;http://blog.csdn.net/apollon_krj/article/details/53398448#0-tsina-1-64987-397232819ff9a47a7b7e80a40613cfe1 所谓半双工通信&#xff0c;即通信双方都可以实现接发数据&#xff0c;但是有一个限制&#xff1a;只能一方发一方收&#xff0c;之后交换收发对…

Linux系统编程(八)线程

Linux系统编程&#xff08;八&#xff09;线程一、什么是线程&#xff1f;二、Linux内核线程实现原理线程共享资源线程非共享资源线程优缺点线程控制原语一、什么是线程&#xff1f; LWP&#xff1a;light weight process 轻量级的进程&#xff0c;本质仍是进程(在Linux环境下…

智能算法(GA、DBO等)求解阻塞流水车间调度问题(BFSP)

先做一个声明&#xff1a;文章是由我的个人公众号中的推送直接复制粘贴而来&#xff0c;因此对智能优化算法感兴趣的朋友&#xff0c;可关注我的个人公众号&#xff1a;启发式算法讨论。我会不定期在公众号里分享不同的智能优化算法&#xff0c;经典的&#xff0c;或者是近几年…

Linux socket编程,对套接字进行封装

转自&#xff1a;http://www.cnblogs.com/-Lei/archive/2012/09/04/2670942.html 下面是对socket操作的封装&#xff0c;因为在Linux下写中文到了windows里面会乱码&#xff0c;所以注释用英文来写&#xff0c;有空再查下解决方法吧 socket.h #ifndef SOCKET_H #define SOCKET_…

Linux系统编程(九)线程同步

Linux系统编程&#xff08;九&#xff09;线程同步一、什么是线程同步&#xff1f;二、互斥量三、条件变量pthread_cond_wait函数pthread_cond_signal函数生产者和消费者模型一、什么是线程同步&#xff1f; 线程同步&#xff0c;指一个线程发出某一功能调用时&#xff0c;在没…

linux网络编程(一)网络基础传输知识

linux网络编程&#xff08;一&#xff09;网络传输基础知识一、什么是协议&#xff1f;二、使用步骤典型协议2.网络应用程序设计模式C/S模式B/S模式优缺点3.分层模型4.TCP/IP四层模型通信过程5.协议格式数据包封装以太网帧格式ARP数据报格式IP段格式UDP数据报格式TCP数据报格式…

linux网络编程:使用多进程实现socket同时收发数据

转载&#xff1a;http://blog.csdn.net/li_wen01/article/details/52685844 前面已讲过使用一个进程实现服务端和客户端P2P通信的实例&#xff0c;但是它只能同时处理一个客户端的连接。如果要实现并发处理多个客户端的连接并且实现P2P通信&#xff0c;可以使用多进程来处理。相…

Linux 进程学习(四)------ sigaction 函数

转自&#xff1a;http://www.cnblogs.com/wblyuyang/archive/2012/11/13/2768923.html 使用 sigaction 函数&#xff1a; signal 函数的使用方法简单&#xff0c;但并不属于 POSIX 标准&#xff0c;在各类 UNIX 平台上的实现不尽相同&#xff0c;因此其用途受 到了一定的限制…

linux网络编程(二)高并发服务器

linux网络编程&#xff08;二&#xff09;高并发服务器错误处理高并发服务器多进程并发服务器客户端错误处理 #include "wrap.h"int Bind(int fd, const struct sockaddr* sa, socklen_t salen) {int ret;if ((ret bind(fd, sa, salen)) < 0){perror("bind…

linux知识(一) 程序、进程与线程

linux知识&#xff08;一&#xff09; 程序、进程与线程程序进程程序如何变成进程&#xff1f;线程线程与进程fork和创建新线程的区别优点程序 程序&#xff1a;程序是已编译好的二进制文件&#xff0c;存储在磁盘中&#xff0c;不占用系统资源 程序包括&#xff1a; RO段&am…

linux 信号signal和sigaction理解

转载&#xff1a;http://blog.csdn.net/beginning1126/article/details/8680757 今天看到unp时发现之前对signal到理解实在浅显&#xff0c;今天拿来单独学习讨论下。 signal&#xff0c;此函数相对简单一些&#xff0c;给定一个信号&#xff0c;给出信号处理函数则可&#xff…

linux知识(二)互斥量、信号量和生产者消费者模型

linux知识&#xff08;二&#xff09;互斥量、信号量和生产者消费者模型一、互斥量产生原因二、信号量生产者消费者模型一、互斥量 产生原因 使用多线程常常会碰到数据混乱的问题&#xff0c;那么使用互斥量&#xff0c;相当于“加锁”的操作&#xff0c;将有助于解决数据混乱…

基于Linux的Socket编程之TCP全双工Server-Client聊天程序

转载&#xff1a;http://blog.csdn.net/apollon_krj/article/details/53437764#0-tsina-1-58570-397232819ff9a47a7b7e80a40613cfe1 一、引言&#xff1a; 由于accept函数、read、write、recv、send等函数都是是阻塞式的&#xff0c;在同一个进程之中&#xff0c;只要有任何一个…

数据结构(一)线性表

数据结构&#xff08;一&#xff09;线性表一、线性表定义二、顺序表定义动态数组三、单链表定义不带头结点带头结点头结点与不带头结点的区别头插法与尾插法双链表循环链表循环单链表循环双链表静态链表一、线性表定义 线性表是具有相同数据类型的n个数据元素的有限序列 特点…

linux网络编程(二)TCP通讯状态

linux网络编程&#xff08;二&#xff09;TCP通讯状态TCP状态转换为什么需要等待2MSL&#xff1f;端口复用TCP状态转换 tcp协议连接开始会经过三次握手&#xff0c;客户端和服务器开始都会处于CLOSED状态 第一次握手&#xff1a;客户端会先发送SYN请求给服务器&#xff0c;客户…

gethostbyname() 函数说明

转载&#xff1a;http://www.cnblogs.com/cxz2009/archive/2010/11/19/1881611.html gethostbyname()函数说明——用域名或主机名获取IP地址 包含头文件 #include <netdb.h> #include <sys/socket.h> 函数原型 struct hostent *gethostbyna…

linux网络编程(三)select、poll和epoll

linux网络编程&#xff08;三&#xff09;select、poll和epoll一、为什么会有多路I/O转接服务器&#xff1f;二、select三、poll三、epoll一、为什么会有多路I/O转接服务器&#xff1f; 为什么会有多路I/O转接服务器呢&#xff1f;在学这个之前&#xff0c;我们同使用的是多线…

Linux socket编程(一) 对套接字操作的封装

转载:http://www.cnblogs.com/-Lei/archive/2012/09/04/2670942.html 以前写的&#xff0c;现在回顾一下&#xff1a; 下面是对socket操作的封装&#xff0c;因为在Linux下写中文到了windows里面会乱码&#xff0c;所以注释用英文来写&#xff0c;有空再查下解决方法吧 socket.…

数据结构(二)栈

栈一、栈顺序栈线性栈(不带头结点)线性栈(带头结点)共享栈一、栈 栈是只允许在一端进行插入或删除操作的线性表。 栈顶&#xff1a;线性表允许进行插入删除的那一端 栈底&#xff1a;固定的&#xff0c;不允许进行插入和删除的那一端 空栈&#xff1a;不含如何元素的空表 顺序…