#相關(guān)代碼, [四號程序員] http://www.coder4.com

/*

?* main.cc

?*

?* ?Created on: 2009-11-30

?* ? ? ?Author: liheyuan

?* ? ?Describe: 非阻塞模式服務器(Echo服務器)

?*

?* ? Last Date: 2009-11-30

?* ? CopyRight: 2009 @ ICT LiHeyuan

?*/

?

#include

using namespace std;

?

#include

#include

#include

#include

#include

#include

#include

#include

#include

#include

?

#define SERVER_PORT 18000

?

#define SERVER_QUEUE 10

#define FD_SET_SIZE 10

#define MAX_BUF 16

?

int main() {

?

?? ?//設(shè)置服務器Addr，在18000，任意IP監(jiān)聽

?? ?int serverFd;

?? ?serverFd = socket(AF_INET, SOCK_STREAM, 0);

?

?? ?/* 設(shè)置 serverFd 為非阻塞方式 */

?? ?int opt = SO_REUSEADDR;

?? ?setsockopt(serverFd, SOL_SOCKET, opt, &opt, sizeof(opt));

?

?? ?struct sockaddr_in serverAddr;

?? ?socklen_t serverAddrLen = sizeof(sockaddr_in);

?? ?serverAddr.sin_addr.s_addr = htonl(INADDR_ANY);

?? ?serverAddr.sin_port = htons(SERVER_PORT);

?

?? ?//綁定

?? ?if (bind(serverFd, (sockaddr*) &serverAddr, serverAddrLen)) {

?? ? ? ?cout << "Binding on " << SERVER_PORT << " fail." << endl;

?? ? ? ?return -1;

?? ?}

?

?? ?//創(chuàng)建等待隊列

?? ?listen(serverFd, SERVER_QUEUE);

?

?? ?//設(shè)定fd_set

?? ?fd_set readfds, testfds;

?? ?FD_ZERO(&readfds);

?? ?FD_SET(serverFd,&readfds);

?

?? ?//非阻塞模式等待客戶連接

?? ?struct sockaddr_in clientAddr;

?? ?int clientFd;

?? ?socklen_t clientAddrLen;

?? ?int len;

?? ?char buf[MAX_BUF];

?? ?while (1) {

?? ? ? ?FD_SET(serverFd,&readfds);

?? ? ? ?testfds = readfds;

?

?? ? ? ?//選擇readfds中可用的fd

?? ? ? ?if (select(FD_SET_SIZE, &testfds, (fd_set *) NULL, (fd_set *) NULL,

?? ? ? ? ? ? ? ?(struct timeval *) NULL) > 0) {

?? ? ? ? ? ?if (FD_ISSET(serverFd,&testfds)) {

?? ? ? ? ? ? ? ?//如果服務器fd可用，則為accept

?? ? ? ? ? ? ? ?clientAddrLen = sizeof(sockaddr_in);

?? ? ? ? ? ? ? ?clientFd =

總結(jié)

以上是生活随笔為你收集整理的linux select 异步,Linux上用select()实现异步的Echo服务器的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。