Linux下使用多线程模拟异步网络通信

服务器

/* socket server
 * 2014-12-15 CopyRight (c) arbboter
 */
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
#include <time.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netdb.h>
#include <string.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <vector>
using namespace std;

vector<int> vecClient;
// 线程同步锁
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;  

void* recv_thr(void*p);
void* send_thr(void*p);
int main()
{
    int sockfd_server;
    int sockfd_client;
    struct sockaddr_in addr_server;
    struct sockaddr_in addr_client;
    socklen_t addr_len = 0;
    int client_max = 10;
    int server_port = 33891;

    srand(time(NULL));

    // create socket
    sockfd_server = socket(AF_INET, SOCK_STREAM, 0);
    if(sockfd_server == -1)
    {
        printf("init socket failed\n");
        return -1;
    }

    // set address
    memset(&addr_server, 0, sizeof(addr_server));
    addr_server.sin_family = AF_INET;
    addr_server.sin_addr.s_addr = htonl(INADDR_ANY);
    addr_server.sin_port = htons(server_port);

    // socket bind with address
    if(bind(sockfd_server, (struct sockaddr*)&addr_server, sizeof(struct sockaddr)) == -1)
    {
        printf("bind socket failed\n");
        return -1;
    }

    // server socket start list, waitting client to connect
    // 这个client_max是指同时连接数
    if(listen(sockfd_server, client_max) == -1)
    {
        printf("start listen socket failed\n");
        return -1;
    }

    // 数据线程
    pthread_t tid = 0;

    pthread_create(&tid, NULL, send_thr, NULL);
    while(1)
    {
        addr_len = sizeof(struct sockaddr_in);
        printf("waitting for connected...\n");

        // waitting for connected
        sockfd_client = accept(sockfd_server, (struct sockaddr*)&addr_client, &addr_len);
        if(sockfd_client == -1)
        {
            printf("accept socket failed\n");
            return -1;
        }

        // create a thread to talk with client
        printf("recived connection from : %s\n", inet_ntoa(addr_client.sin_addr));
        pthread_create(&tid, NULL, recv_thr, (void*)&sockfd_client);

        // 加到发数据对象集合中
        pthread_mutex_lock(&mutex);
        vecClient.push_back(sockfd_client);
        pthread_mutex_unlock(&mutex);
    }
    close(sockfd_server);
    pthread_mutex_destroy(&mutex);
    return 0;
}

// 收数据
void* recv_thr(void*p)
{
    int fd = *((int*)p);
    int nRead = 0;
    char szBuf[512] = {0};

    while(1)
    {
        memset(szBuf, 0, sizeof(szBuf));
        nRead = read(fd, szBuf, sizeof(szBuf));
        printf("client : %s\n", szBuf);

        if(strcmp(szBuf, "quit") == 0)
        {
            break;
        }

        sprintf(szBuf, "Your magic number is : %d", rand()%100);
        printf("server : %s\n", szBuf);
        write(fd, szBuf, strlen(szBuf));
    }
    return NULL;
}

// 发数据
void* send_thr(void*p)
{
    size_t i = 0;
    char szBuf[512] = {0};

    while(1)
    {
        sleep(rand()%10);
        pthread_mutex_lock(&mutex);
        for(int i=0; i<vecClient.size(); i++)
        {
            sprintf(szBuf, "Your magic number is : %d", rand()%100);
            printf("[%02d] server : %s\n", i, szBuf);
            write(vecClient[i], szBuf, strlen(szBuf));
        }
        pthread_mutex_unlock(&mutex);
    }
    return NULL;
}

客户端

/* socket client
 * 2014-12-15 CopyRight (c) arbboter
 */
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netdb.h>
#include <string.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <signal.h>
#include <errno.h>
#include <string.h>

void* recv_thr(void*p);
int main()
{
    int sockfd_server;
    struct sockaddr_in addr_server;
    socklen_t addr_len = 0;
    int server_port = 33891;
    char* server_addr = "192.168.2.200";

    // create socket
    sockfd_server = socket(AF_INET, SOCK_STREAM, 0);
    if(sockfd_server == -1)
    {
        printf("init socket failed\n");
        return -1;
    }

    // set server address
    memset(&addr_server, 0, sizeof(addr_server));
    addr_server.sin_family = AF_INET;
    addr_server.sin_addr.s_addr = inet_addr(server_addr);;
    addr_server.sin_port = htons(server_port);

    // connect server
    if(connect(sockfd_server,(struct sockaddr *)&addr_server,sizeof(struct sockaddr))==-1)
    {
        printf("connect server failed\n");
        return -1;
    }

    // 启动收数据线程
    pthread_t tid = 0;
    pthread_create(&tid, NULL, recv_thr, (void*)&sockfd_server);

    // 发送数据
    char szBuf[512] = {0};
    int nLen = 0;
    while(1)
    {
        // 收线程已退出
        if( ESRCH == pthread_kill(tid,0) )
        {
            break;
        }
        // 等待输入数据
        gets(szBuf);
        nLen = strlen(szBuf);
        if(nLen > 0)
        {
            szBuf[nLen] = ‘\0‘;
            write(sockfd_server, szBuf, nLen);
        }
    }
    close(sockfd_server);
    return 0;
}

// 收数据
void* recv_thr(void*p)
{
    int fd = *((int*)p);
    int nRead = 0;
    char szBuf[512] = {0};

    while(1)
    {
        memset(szBuf, 0, sizeof(szBuf));
        nRead = read(fd, szBuf, sizeof(szBuf));
        printf("server : %s\n", szBuf);

        if(strcmp(szBuf, "quit") == 0)
        {
            break;
        }
    }
    return NULL;
}
时间: 2024-10-10 20:28:37

Linux下使用多线程模拟异步网络通信的相关文章

【转】Linux下的多线程编

作者:gnuhpc 出处:http://www.cnblogs.com/gnuhpc/原文链接:http://www.cnblogs.com/gnuhpc/archive/2012/12/07/2807484.html 本文作者: 姚继锋 (2001-08-11 09:05:00) 黄鹏程(2009-03-13) converse (2009-01-15) 1 引言 线程(thread)技术早在60年代就被提出,但真正应用多线程到操作系统中去,是在80年代中期,solaris是这方面的佼佼者.传

【转】Linux下的多线程编程

1 引言 线程(thread)技术早在60年代就被提出,但真正应用多线程到操作系统中去,是在80年代中期,solaris是这方面的佼佼者.传统的 Unix也支持线程的概念,但是在一个进程(process)中只允许有一个线程,这样多线程就意味着多进程.现在,多线程技术已经被许多操作系统所支持,包括Windows也包括Linux.  为什么有了进程的概念后,还要再引入线程呢?使用多线程到底有哪些好处?什么的系统应该选用多线程?我们首先必须回答这些问题.  使用多线程的理由之一是和进程相比,它是一种非

Linux下的多线程编程

1 引言 线程(thread)技术早在60年代就被提出,但真正应用多线程到操作系统中去,是在80年代中期,solaris是这方面的佼佼者.传统的 Unix也支持线程的概念,但是在一个进程(process)中只允许有一个线程,这样多线程就意味着多进程.现在,多线程技术已经被许多操作系统所支 持,包括Windows也包括Linux. 为什么有了进程的概念后,还要再引入线程呢?使用多线程到底有哪些好处?什么的系统应该选用多线程?我们首先必须回答这些问题. 使用多线程的理由之一是和进程相比,它是一种非常

linux下的多线程

1 引言 线程(thread)技术早在60年代就被提出,但真正应用多线程到操作系统中去,是在80年代中期,solaris是这方面的佼佼者.传统的Unix也支持线程的概念,但是在一个进程(process)中只允许有一个线程,这样多线程就意味着多进程.现在,多线程技术已经被许多操作系统所支持,包括Windows/NT,当然,也包括Linux. 为什么有了进程的概念后,还要再引入线程呢?使用多线程到底有哪些好处?什么的系统应该选用多线程?我们首先必须回答这些问题. 使用多线程的理由之一是和进程相比,它

Linux 下基于多线程服务器/客服端聊天程序源码

Linux 下基于多线程服务器/客服端聊天程序,采用阻塞的socket技术,和多线程技术实现. 客服端程序:client.c #include<stdio.h> #include<stdlib.h> #include<string.h> #include <sys/types.h> #include <sys/socket.h> #include <netinet/in.h> #include <netinet/ip.h>

linux下php pcntl_fork模拟多线程

开始用php写后台服务一段时间了.也是在这样的驱动下,不断的学习php语法,体验这一原来一直以为神秘且敬而远之的神奇语言的魅力.最初看php多线程的资料是为了提高程序的处理能力,充分发挥linux多任务的优势.不曾想多线程没用成反到是带来了一系列的意外收获.让之后的许多问题迎刃而解,不敢独享特一一道来. 本文所讲的东西是源自php的pcntl_fork函数.因为这个函数依赖操作系统fork的实现,所以本文所讲的东西只适用于linux/unix.ok,那么先看看这个函数的用法吧.php手册上是这么

Linux下基于多线程的echo

准备开始写一些Linux 下网络编程以及多线程的blog,就从这个简单的echo程序开始吧. 在echo的服务端使用多线程与客户进行通信,可以实现一个服务端程序同时连接多个客户的功能.那么,到底在服务端要有多少个线程呢? 答案是:1+1+n.一个主线程,一个监听(listen)线程,与n个客户进行通信的n个线程. 服务端代码: 1 #include "../unp.h" 2 #include <pthread.h> 3 4 void* str_echo(void* argv

linux下使用多线程编写的聊天室

自从开始学linux网络编程后就想写个聊天室,一开始原本打算用多进程的方式来写,可是发觉进程间的通信有点麻烦,而且开销也大,后来想用多线程能不能实现呢,于是便去看了一下linux里线程的用法,实际上只需要知道 pthread_create 就差不多了,于是动手开干,用了两天时间,调试的过程挺痛苦的,一开始打算用纯C来撸,便用简单的数组来存储客户端的连接信息,可是运行时出现了一些很奇怪的问题,不知道是不是访问了临界资源,和线程间的互斥有关等等:奇怪的是,当改用STL的set或map时问题就解决了,

LInux下使用USB模拟ACM串口设备

这个想法之前就在脑袋里有过,最近公司产品要用到,所以多做了些了解. 1. USB 简介 USB 是 Universal Serial Bus 的缩写,从字面上看,就是通用串行总线的意思.从物理上看,其实就是一对差分线,连接两台设备后,相互间进行数据传输.加上另外两路供电( 5V 和 GND)线,一共是 4 根线. 那么,既然是只有一对差分线,那么该如何决定由谁传给谁呢(如果两边同时在线上建立电平,线路上的电平会是不确定态的,以致无法通信)?这就要说到 USB 传输的一个重要基础:“询问-应答”