欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

c語言多進(jìn)程tcp服務(wù)器示例

 更新時(shí)間:2014年03月06日 10:31:10   作者:  
這篇文章主要介紹了c語言多進(jìn)程tcp服務(wù)器示例,多進(jìn)程socket,epoll實(shí)現(xiàn)IO復(fù)用,需要的朋友可以參考下

server.h

復(fù)制代碼 代碼如下:

#ifndef SERVER_H
#define SERVER_H
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <assert.h>
#include <sys/epoll.h>
#include <signal.h>
#include <fcntl.h>
#include "bussiness.h"
#define LISTENTQ 5
#define DEF_PORT 6000
#define MAX_EPOLL_SIZE 10
#define DEF_PROCESS_NUM 5
int create_tcpsvr(char *ip, int port);
void fill_sockaddr(struct sockaddr_in *addr,char *ip, int port);
void comm_to_client(int sockfd);
void epoll_business(int epollfd, int listenfd, struct epoll_event ev);
int init_epoll(int listenfd);
void create_process(int sockfd, int i);
#endif

server.c

復(fù)制代碼 代碼如下:

#include "server.h"
/*
 * Create a TCP Server
 * Return socketfd
 */
int create_tcpsvr(char *ip,int port)
{
    int sockfd;
    struct sockaddr_in addr;

    if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == EOF){
        perror("create_tcpsvr(),socket()");
        exit(EXIT_FAILURE);
    }

    fill_sockaddr(&addr,ip,port);

    if (bind(sockfd, (struct sockaddr *)&addr, sizeof(addr)) == EOF){
        perror("create_tcpsvr(),bind()");
        exit(EXIT_FAILURE);
    }

    if (listen(sockfd,LISTENTQ) == EOF) {
        perror("create_tcpsvr(),bind()");
        exit(EXIT_FAILURE);
    }
    return sockfd;
}

/**
 * Set TCP server's address
 */
void fill_sockaddr(struct sockaddr_in *addr, char *ip, int port)
{
    assert(addr);

    addr -> sin_family = AF_INET;
    addr -> sin_port = htons(port?port:DEF_PORT);
    if (ip == NULL) {
        addr -> sin_addr.s_addr = htonl(INADDR_ANY);
    } else if((addr -> sin_addr.s_addr = inet_addr(ip)) == EOF) {
       perror("fill_sockaddr(),inet_addr()");
       exit(EXIT_FAILURE);
    }
}
/*
 * Communicate to client
 */
void comm_to_clt(int listenfd)
{   
    printf("TCP SERVER IS WAITING!\n");

    struct epoll_event events[MAX_EPOLL_SIZE];
    int fd_num;

    int epollfd = init_epoll(listenfd);

    while (1) {

        fd_num = epoll_wait(epollfd,events,MAX_EPOLL_SIZE,-1);
        if (fd_num == EOF) {
            perror("comm_to_clt(),epoll_wait()");
            continue;
        }
        while (--fd_num >= 0) {
            epoll_business(epollfd, listenfd, events[fd_num]);
        }
    }   
}
/*
 * Initlization epoll
 */
int init_epoll(int listenfd)
{
    struct epoll_event ev;
    int epollfd;

    if((epollfd = epoll_create(MAX_EPOLL_SIZE)) == EOF) {
        perror("init_epoll(),epoll_create()");
        exit(EXIT_FAILURE);
    }

    ev.events = EPOLLIN;
    ev.data.fd = listenfd;
    if (epoll_ctl(epollfd, EPOLL_CTL_ADD,listenfd, &ev)) {
        perror("init_epoll(),epoll_ctl()");
        exit(EXIT_FAILURE);
    }
    return epollfd;
}

/*
 * Respond for io change
 */
void epoll_business(int epollfd, int listenfd, struct epoll_event ev)
{
    struct epoll_event ev_n;
    if (ev.data.fd == listenfd) {
        int clt_fd = accept(listenfd, 0, 0);
        if (clt_fd == EOF) {
            perror("epoll_business(), accept()");
            return;
        }

        fcntl(clt_fd, F_SETFL, O_NONBLOCK);
        ev_n.events = EPOLLIN|EPOLLET;
        ev_n.data.fd = clt_fd;
        if (epoll_ctl(epollfd,EPOLL_CTL_ADD, clt_fd, &ev_n) == EOF) {
            perror("epoll_business(), epoll_ctl()");
            return;
        }
    }else {
        main_service(ev.data.fd);
        if (epoll_ctl(epollfd,EPOLL_CTL_DEL, ev.data.fd, &ev) == EOF) {
            perror("epoll_business(), epoll_ctl()");
        }
        close(ev.data.fd);
    }
}
/*
 * Create some process
 */

void create_process(int sockfd, int i)
{
    /*
     * Avoid zombie process
     */
    signal(SIGCHLD,SIG_IGN);

    while (i--) {
        if (fork() == 0) {
            comm_to_clt(sockfd);
        }
    }
    while(1){
        sleep(100);
    }
}
int main(int argc, char *argv[])
{
    int sockfd = create_tcpsvr(0, 0);
    create_process(sockfd,DEF_PROCESS_NUM);
    exit(EXIT_SUCCESS);
}

bussiness.h

復(fù)制代碼 代碼如下:

#ifndef BUSSINESS_H
#define BUSSINESS_H
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <assert.h>
#define BUFF_SIZE 4096
void main_service(int sockfd);
int write_sock(int sockfd, char *buff, size_t length);
int read_sock(int sockfd, char *buff, size_t llength);
#endif


bussiness.c

復(fù)制代碼 代碼如下:

#include "bussiness.h"

void main_service(int sockfd)
{
    char buff[BUFF_SIZE];
    size_t buff_len;
    if ((buff_len = read_sock(sockfd, buff, BUFF_SIZE)) == EOF) {
        perror("main_service(),read_sock()");
        return;
    } else {
  //業(yè)務(wù)邏輯從這里開始
        printf("%s", buff);
    }

}
/*
 * Recive messages
 * Return the length
 */
int read_sock(int sockfd, char *buff, size_t length)
{
    assert(buff);
    return read(sockfd, buff, length);
}
/*
 * Send messages
 * Return the length
 */
int write_sock(int sockfd, char *buff,size_t length)
{
    assert(buff);
    return write(sockfd, buff, length);
}

相關(guān)文章

  • visual?studio?2022一個(gè)不易發(fā)現(xiàn)的問題

    visual?studio?2022一個(gè)不易發(fā)現(xiàn)的問題

    本文主要介紹了visual?studio?2022一個(gè)不易發(fā)現(xiàn)的問題,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2022-07-07
  • c++中priority_queue模擬的實(shí)現(xiàn)

    c++中priority_queue模擬的實(shí)現(xiàn)

    priority_queue是C++標(biāo)準(zhǔn)庫中的一個(gè)容器適配器,用于實(shí)現(xiàn)優(yōu)先隊(duì)列的數(shù)據(jù)結(jié)構(gòu),本文主要介紹了c++中priority_queue模擬的實(shí)現(xiàn),具有一定的參考價(jià)值,感興趣的可以了解一下
    2024-09-09
  • C++ pair的用法案例詳解

    C++ pair的用法案例詳解

    這篇文章主要介紹了C++ pair的用法案例詳解,本篇文章通過簡(jiǎn)要的案例,講解了該項(xiàng)技術(shù)的了解與使用,以下就是詳細(xì)內(nèi)容,需要的朋友可以參考下
    2021-09-09
  • C語言實(shí)現(xiàn)輸出各種三角形

    C語言實(shí)現(xiàn)輸出各種三角形

    這篇文章主要介紹了C語言實(shí)現(xiàn)輸出各種三角形方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-12-12
  • 快速模式匹配算法(KMP)的深入理解

    快速模式匹配算法(KMP)的深入理解

    本篇文章是對(duì)快速模式匹配算法(KMP)進(jìn)行了詳細(xì)的分析介紹,需要的朋友參考下
    2013-05-05
  • QT計(jì)算時(shí)間差的方法詳解

    QT計(jì)算時(shí)間差的方法詳解

    這篇文章主要為大家詳細(xì)介紹了利用QT實(shí)現(xiàn)計(jì)算兩個(gè)時(shí)間的時(shí)間差的方法,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下
    2023-12-12
  • C++遍歷文件夾下所有文件的多種方法

    C++遍歷文件夾下所有文件的多種方法

    這篇文章主要介紹了C++遍歷文件夾下所有文件的多種方法,需要的朋友可以參考下
    2018-01-01
  • c++矩陣計(jì)算性能對(duì)比:Eigen和GPU解讀

    c++矩陣計(jì)算性能對(duì)比:Eigen和GPU解讀

    這篇文章主要介紹了c++矩陣計(jì)算性能對(duì)比:Eigen和GPU解讀,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-12-12
  • 如何尋找數(shù)組中的第二大數(shù)

    如何尋找數(shù)組中的第二大數(shù)

    本篇文章是對(duì)如何尋找數(shù)組中的第二大數(shù)進(jìn)行了詳細(xì)的分析介紹,需要的朋友參考下
    2013-05-05
  • c++ 子類構(gòu)造函數(shù)初始化及父類構(gòu)造初始化的使用

    c++ 子類構(gòu)造函數(shù)初始化及父類構(gòu)造初始化的使用

    這篇文章主要介紹了c++ 子類構(gòu)造函數(shù)初始化及父類構(gòu)造初始化的使用,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-07-07

最新評(píng)論