linux套接字编程之多进程多线程练习




一.概述:本次练习的是linux下的TAP/IP套接字多进程与多线程编程,功能只实现了对话。话不多说,直接上代码。




二.多进程:

server.c:

1 /****************************************
  2     > File Name:server.c
  3     > Author:xiaoxiaohui
  4     > mail:[email protected]
  5     > Created Time:2016年05月15日 星期日 16时06分03秒
  6 ****************************************/
  7 
  8 #include<stdio.h>
  9 #include<stdlib.h>                                                                                                                        
 10 #include<sys/types.h>
 11 #include<sys/socket.h>
 12 #include<unistd.h>
 13 #include <arpa/inet.h>
 14 #include<netinet/in.h>
 15 #include<fcntl.h>
 16 #include<string.h>
 17 #include<fcntl.h>
 18 
 19 #define LEN 1024
 20 const int PORT = 8080;
 21 int listenSock, linkSock;
 22 struct sockaddr_in lockal;
 23 struct sockaddr_in client;
 24 char buf[LEN];
 25 
 26 
 27 void ListenSock()    //建立一个已链接套接字
 28 {
 29     listenSock = socket(AF_INET, SOCK_STREAM, 0);   //返回一个文件描述符
 30 
 31     lockal.sin_family = AF_INET;
 32     lockal.sin_addr.s_addr = htonl(INADDR_ANY);    //适合多网卡
 33     lockal.sin_port = htons(PORT);
 34     if( bind(listenSock, (struct sockaddr*)&lockal, sizeof(lockal)) < 0)   //绑定本地地址
 35     {
 36         perror("bind");
 37         exit(0);
 38     }
 39 
 40     if( listen(listenSock, 5) < 0)    //进入监听状态
 41     {
 42         perror("listen");
 43         exit(1);
 44     }
 45 }
 46 
 47 void LinkSock()
 48 {
 49     int size = sizeof(lockal);
 50     linkSock = accept(listenSock, (struct sockaddr*)&client, &size);  //创建一个已链接套接字
 51     if(linkSock < 0)
 52     {
 53         perror("accept");
 54     }
 55     else
 56     {
 57         printf("connect success ip is :%s port is : %d\n",inet_ntoa(client.sin_addr),ntohs(client.sin_port));
 58     }
 59 }
 60 
 61 int main()
 62 {
 63     ListenSock();
 64     while(1)
 65     {
 66         LinkSock();
 67 
 68         pid_t pid = fork();
 69 
 70         if(pid == 0)
 71         {
 72             close(listenSock);
 73             while(1)
 74             {
 75                 int ret = 0;                                                                                                              
 76                 ret = read(linkSock, buf, LEN);
 77                 buf[ret] = ‘\0‘;
 78                 printf("client->ip:%s port: %d  #%s\n",inet_ntoa(client.sin_addr), 79                         ntohs(client.sin_port), buf);
 80             }
 81         }
 82         else if(pid > 0)
 83         {
 84             close(linkSock);
 85         }
 86         else
 87         {
 88             perror("fork");
 89             continue;
 90         }
 91     }
 92 
 93     return 0;
 94 }
 95 
 96

client.c:

 1 /****************************************                                                                                                 
  2     > File Name:client.c
  3     > Author:xiaoxiaohui
  4     > mail:[email protected]
  5     > Created Time:2016年05月15日 星期日 16时48分21秒
  6 ****************************************/
  7 
  8 
  9 #include<stdio.h>
 10 #include<stdlib.h>
 11 #include<sys/types.h>
 12 #include<sys/socket.h>
 13 #include<unistd.h>
 14 #include <arpa/inet.h>
 15 #include<netinet/in.h>
 16 #include<fcntl.h>
 17 #include<string.h>
 18 #include<fcntl.h>
 19 const int PORT = 8080;
 20 const int LEN = 1024;
 21 int clientSock;
 22 struct sockaddr_in server;
 23 
 24 
 25 
 26 void LinkSock()  //创建一个以链接套接字
 27 {
 28     clientSock = socket(AF_INET, SOCK_STREAM, 0);
 29 
 30     server.sin_family = AF_INET;
 31     server.sin_addr.s_addr = inet_addr("127.0.0.1");
 32     server.sin_port = htons(PORT);
 33     if( connect(clientSock, (struct sockaddr*)&server, sizeof(server)) < 0)
 34     {
 35         perror("connect");
 36         exit(0);
 37     }
 38     else
 39     {
 40         printf("connect success!   ip:%s  port:%d\n", inet_ntoa(server.sin_addr), ntohs(server.sin_port));
 41     }
 42 }
 43 
 44 int main()
 45 {
 46 
 47     char buf[LEN];
 48     LinkSock();     //得到一个已链接套接字
 49 
 50     while(1)
 51     {
 52         int ret = 0;
 53         printf("请选择->");
 54         gets(buf);
 55 
 56         write(clientSock, buf, strlen(buf));     //把选择的命令发到服务器
 57 
 58         //memset(buf, ‘\0‘, LEN);
 59         //ret = read(clientSock, buf, LEN - 1 );   //接受服务器的信息
 60         //buf[ret] = ‘\0‘;
 61         //printf("%s", buf);
 62         //printf("\n");
 63     }
 64 
 65     return 0;
 66 }
 67

执行结果:




三.多线程:

server.c:

 1 /****************************************                                                                                                 
  2     > File Name:server.c
  3     > Author:xiaoxiaohui
  4     > mail:[email protected]
  5     > Created Time:2016年05月15日 星期日 16时06分03秒
  6 ****************************************/
  7 
  8 #include<stdio.h>
  9 #include<stdlib.h>
 10 #include<sys/types.h>
 11 #include<sys/socket.h>
 12 #include<unistd.h>
 13 #include <arpa/inet.h>
 14 #include<netinet/in.h>
 15 #include<fcntl.h>
 16 #include<string.h>
 17 #include<fcntl.h>
 18 #include<pthread.h>
 19 
 20 #define LEN 1024
 21 const int PORT = 8080;
 22 int listenSock, linkSock;
 23 struct sockaddr_in lockal;
 24 struct sockaddr_in client;
 25 char buf[LEN];
 26 
 27 
 28 void ListenSock()    //建立一个已链接套接字
 29 {
 30     listenSock = socket(AF_INET, SOCK_STREAM, 0);   //返回一个文件描述符
 31 
 32     lockal.sin_family = AF_INET;
 33     lockal.sin_addr.s_addr = htonl(INADDR_ANY);    //适合多网卡
 34     lockal.sin_port = htons(PORT);
 35     if( bind(listenSock, (struct sockaddr*)&lockal, sizeof(lockal)) < 0)   //绑定本地地址
 36     {
 37         perror("bind");
 38         exit(0);
 39     }
 40 
 41     if( listen(listenSock, 5) < 0)    //进入监听状态
 42     {
 43         perror("listen");
 44         exit(1);
 45     }
 46 }
 47 
 48 void LinkSock()
 49 {
 50     int size = sizeof(lockal);
 51     linkSock = accept(listenSock, (struct sockaddr*)&client, &size);  //创建一个已链接套接字
 52     if(linkSock < 0)
 53     {
 54         perror("accept");
 55     }
 56     else
 57     {
 58         printf("connect success ip is :%s port is : %d\n",inet_ntoa(client.sin_addr),ntohs(client.sin_port));
 59     }
 60 }
 61 
 62 void* RecvMessage(void* ptr)
 63 {
 64     while(1)
 65     {
 66         int ret = 0;
 67         ret = read(linkSock, buf, LEN);
 68         buf[ret] = ‘\0‘;
 69         printf("client->ip:%s port: %d  #%s\n",inet_ntoa(client.sin_addr), 70         ntohs(client.sin_port), buf);
 71     }
 72     return NULL;
 73 }
 74 
 75 int main()                                                                                                                                
 76 {
 77     ListenSock();
 78     while(1)
 79     {
 80         LinkSock();
 81 
 82         pthread_t tid;
 83         int err = pthread_create(&tid, NULL, RecvMessage, NULL);
 84         pthread_detach(tid);
 85     }
 86 
 87     return 0;
 88 }
 89 
 90

client.c:

1 /****************************************                                                                                                 
  2     > File Name:client.c
  3     > Author:xiaoxiaohui
  4     > mail:[email protected]
  5     > Created Time:2016年05月15日 星期日 16时48分21秒
  6 ****************************************/
  7 
  8 
  9 #include<stdio.h>
 10 #include<stdlib.h>
 11 #include<sys/types.h>
 12 #include<sys/socket.h>
 13 #include<unistd.h>
 14 #include <arpa/inet.h>
 15 #include<netinet/in.h>
 16 #include<fcntl.h>
 17 #include<string.h>
 18 #include<fcntl.h>
 19 const int PORT = 8080;
 20 const int LEN = 1024;
 21 int clientSock;
 22 struct sockaddr_in server;
 23 
 24 
 25 
 26 void LinkSock()  //创建一个以链接套接字
 27 {
 28     clientSock = socket(AF_INET, SOCK_STREAM, 0);
 29 
 30     server.sin_family = AF_INET;
 31     server.sin_addr.s_addr = inet_addr("127.0.0.1");
 32     server.sin_port = htons(PORT);
 33     if( connect(clientSock, (struct sockaddr*)&server, sizeof(server)) < 0)
 34     {
 35         perror("connect");
 36         exit(0);
 37     }
 38     else
 39     {
 40         printf("connect success!   ip:%s  port:%d\n", inet_ntoa(server.sin_addr), ntohs(server.sin_port));
 41     }
 42 }
 43 
 44 int main()
 45 {
 46 
 47     char buf[LEN];
 48     LinkSock();     //得到一个已链接套接字
 49 
 50     while(1)
 51     {
 52         int ret = 0;
 53         printf("请选择->");
 54         gets(buf);
 55 
 56         write(clientSock, buf, strlen(buf));     //把选择的命令发到服务器
 57 
 58         //memset(buf, ‘\0‘, LEN);
 59         //ret = read(clientSock, buf, LEN - 1 );   //接受服务器的信息
 60         //buf[ret] = ‘\0‘;
 61         //printf("%s", buf);
 62         //printf("\n");
 63     }
 64 
 65     return 0;
 66 }
 67

执行结果:

时间: 2024-10-12 01:56:20

linux套接字编程之多进程多线程练习的相关文章

linux 套接字编程入门--Hello World

下述代码是linux套接字编程的入门代码.分为服务端和客户端源码. 服务端代码的主要流程是绑定ip地址和端口号建立套接字,等待客户端发起访问.接受客户端请求之后,向客户端发送字符串"hello world",关闭套接字,结束程序. 客户端代码的主要流程是向服务端对应的套接字发起请求,读取服务端发送的数据,并且打印出来. 代码已经详细注释,更多细节不再赘述. server.cpp #include<stdio.h> #include<stdlib.h> #incl

Linux 套接字编程 - select

select 可以感知文件表述符集合中的变化,如果办fd0(即标准输入)放入select的read fd set,发现只有按回车的时候select才会返回.查了下要把终端的缓冲大小设为1,这样就能实现击键后马上反应了. #include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <errno.h> #include <termio.h> #include <sys/

Linux 套接字编程 - TCP连接基础

第五章的内容,实现一个echo服务器和对应的客户端,主要收获: 0. TCP socket编程主要基本步骤 1. SIGCHLD信号含义(子进程退出时向父进程发送,提醒父进程对其状态信息进行一个获取),waitpid 和 wait在使用上的差异,前者可以配置参数设定为非阻塞方式调用,更加灵活. 2. 信号处理函数与其过程(尤其是信号发生后不列队这个性质),相同的信号多次发生(间隔非常接近的话)可能仅会调用一次信号处理函数 3. 信号处理对慢系统(阻塞)调用如accept等的影响(如果信号处理设置

Linux 套接字编程中的 5 个隐患(转)

本文转自IBM博文Linux 套接字编程中的 5 个隐患. “在异构环境中开发可靠的网络应用程序”. Socket API 是网络应用程序开发中实际应用的标准 API.尽管该 API 简单,但是开发新手可能会经历一些常见的问题.本文识别一些最常见的隐患并向您显示如何避免它们. 在 4.2 BSD UNIX® 操作系统中首次引入,Sockets API 现在是任何操作系统的标准特性.事实上,很难找到一种不支持 Sockets API 的现代语言.该 API 相当简单,但新的开发人员仍然会遇到一些常

Linux 套接字编程中的 5 个隐患

在异构环境中开发可靠的网络应用程序 M. Tim Jones ([email protected]), 资深软件工程师, Emulex 简介: Socket API 是网络应用程序开发中实际应用的标准 API.尽管该 API 简单,但是开发新手可能会经历一些常见的问题.本文识别一些最常见的隐患并向您显示如何避免它们. 发布日期: 2005 年 10 月 08 日 级别: 中级 访问情况 : 13059 次浏览 评论: 0 (查看 | 添加评论 - 登录)  平均分 (34个评分)为本文评分 在

Linux套接字编程

网络中的进程是如何通信的? 在网络中进程之间进行通信的时候,那么每个通信的进程必须知道它要和哪个计算机上的哪个进程通信.否则通信无从谈起!在本地可以通过进程PID来唯一标识一个进程,但是在网络中这是行不通的.其实TCP/IP协议族已经帮我们解决了这个问题,网络层的“ip地址”可以唯一标识网络中的主机,而传输层的“协议+端口”可以唯一标识主机中的应用程序(进程).这样利用三元组(ip地址,协议,端口)就可以标识网络的进程了,网络中的进程通信就可以利用这个标志与其它进程进行交互. 什么是套接字? 套

linux套接字编程练习之网络选课模拟

  1 /****************************************                                                                                                    2     > File Name:server.c   3     > Author:xiaoxiaohui   4     > mail:[email protected]   5     >

Linux 套接字编程中要注意的细节

隐患 1.忽略返回状态 第一个隐患很明显,但它是开发新手最容易犯的一个错误.如果您忽略函数的返回状态,当它们失败或部分成功的时候,您也许会迷失.反过来,这可能传播错误,使定位问题的源头变得困难. 捕获并检查每一个返回状态,而不是忽略它们.考虑清单 1 显示的例子,一个套接字 send 函数. 清单 1. 忽略 API 函数返回状态 int status, sock, mode; /* Create a new stream (TCP) socket */ sock = socket( AF_IN

【转】Linux 套接字编程中的 5 个隐患

地址:请点击这里