c语言多进程tcp服务器示例

 更新时间:2014年03月06日 10:31:10   作者:  
这篇文章主要介绍了c语言多进程tcp服务器示例,多进程socket,epoll实现IO复用,需要的朋友可以参考下

server.h

复制代码 代码如下:

#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

复制代码 代码如下:

#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

复制代码 代码如下:

#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

复制代码 代码如下:

#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 {
  //业务逻辑从这里开始
        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);
}

相关文章

  • C语言中的三种循环语句

    C语言中的三种循环语句

    这篇文章主要介绍了C语言中的三种循环语句,在C语言中循环可分为3中,while循环、do - while循环、for 循环。下面小编就来为大家讲解这三种循环语句,需要的朋友可以参考一下,希望对你有所帮助
    2021-10-10
  • C++之BOOST字符串查找示例

    C++之BOOST字符串查找示例

    这篇文章主要介绍了C++之BOOST字符串查找的方法,实例演示了boost针对字符串的查找、判定及替换等操作,具有一定的实用价值,需要的朋友可以参考下
    2014-10-10
  • C语言中求和、计算平均值、方差和标准差的实例

    C语言中求和、计算平均值、方差和标准差的实例

    这篇文章主要介绍了C语言中求和、计算平均值、方差和标准差的实例,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-12-12
  • 浅谈VC中预编译的头文件放那里的问题分析

    浅谈VC中预编译的头文件放那里的问题分析

    本篇文章是对VC中预编译的头文件放那里的问题进行了详细的分析介绍,需要的朋友参考下
    2013-05-05
  • OpenCV实现图像校正功能

    OpenCV实现图像校正功能

    这篇文章主要为大家详细介绍了OpenCV实现图像校正功能,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-05-05
  • C++中volatile关键字及常见的误解总结

    C++中volatile关键字及常见的误解总结

    这篇文章主要给大家介绍了关于C++中volatile关键字及常见的误解的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2018-05-05
  • C++实现将简单密码译回原文的方法

    C++实现将简单密码译回原文的方法

    这篇文章主要介绍了C++实现将简单密码译回原文的方法,可实现将简单的字母位移类型的密码译回原文的功能,涉及C++简单字符串操作相关技巧,需要的朋友可以参考下
    2016-05-05
  • 浅谈C++空间配置器allocator

    浅谈C++空间配置器allocator

    在STL中,Memory Allocator处于最底层的位置,为一切的Container提供存储服务,是一切其他组件的基石。对于一般使用 STL 的用户而言,Allocator是不可见的。本文将主要介绍C++空间配置器allocator
    2021-06-06
  • C语言中字符串的内存地址操作的相关函数简介

    C语言中字符串的内存地址操作的相关函数简介

    这篇文章主要介绍了C语言中字符串的内存地址操作的相关函数,包括bcopy()函数和bzero()函数以及bcmp()函数,需要的朋友可以参考下
    2015-08-08
  • C++改变编程入口为main函数

    C++改变编程入口为main函数

    这篇文章主要介绍了C++改变编程入口为main函数的方法的相关资料,需要的朋友可以参考下
    2015-06-06

最新评论