设置非阻塞socket收发数据

非阻塞式I/O包括非阻塞输入操作，非阻塞输出操作，非阻塞接收外来连接，非阻塞发起外出连接。包括的函数有：read, readv, recv, recvfrom, recvmsg, write, writev, send, sendto, sendmsg, accept。

将socket 设置为非阻塞模式有三种方法：

（1）创建socket的时候，指定socket是异步的，在type的参数中设置SOCK_NONBLOCK标志即可。

[objc] view plain copy

int socket(int domain, int type, int protocol);
int s = socket(AF_INET, SOCK_STREAM | SOCK_NONBLOCK, IPPROTO_TCP);

（2）使用fcntl函数：[objc] view plain copy

fcntl(sockfd, F_SETFL, fcntl(sockfd, F_GETFL, 0) | O_NONBLOCK);

（3）使用ioctl函数：[objc] view plain copy

ioctl(sockfd, FIONBIO, 1); //1:非阻塞 0:阻塞

下面改写linux网络编程:使用多进程实现socket同时收发数据中的程序[objc] view plain copy

/*=============================================================================
# FileName: nonblocktcp.c
# Desc: set the connetfd unblock
# Author: licaibiao
# LastChange: 2017-02-14
=============================================================================*/
#include<stdio.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<unistd.h>
#include<stdlib.h>
#include<errno.h>
#include<arpa/inet.h>
#include<netinet/in.h>
#include<string.h>
#include<signal.h>
#include <fcntl.h>
#define MAXLINE 256
#define PORT 6666
void process_out(int signo)
{
exit(EXIT_SUCCESS);
}
void write_func(int pid, int fd)
{
char* write = "I am server";
printf("write id = %d\n",pid);
signal(SIGUSR1,process_out);
while(1)
{
sleep(1);
send(fd,write,strlen(write)+1,0);
}
}
void read_func(int pid, int fd)
{
char readbuff[MAXLINE];
int n = 0;
printf("read id = %d \n",pid);
memset(&readbuff,0,sizeof(readbuff));
while(1)
{
n = recv(fd, readbuff, MAXLINE, 0);
if(n > 0)
{
printf("server recv data: %s \n",readbuff);
}
else if(n == 0)
{
break;
}
sleep(1);
//printf("===\n");
};
printf("exit read function\n");
kill(pid, SIGUSR1);
exit(EXIT_SUCCESS);
}
int main(void)
{
int listenfd,connetfd;
int on = 1;
int addrlen = 0;
int flags;
pid_t pid, pid_child, pid_send;
struct sockaddr_in server_addr;
struct sockaddr_in client_addr;
if ((listenfd = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0)
{
printf("create socket err \n");
}
addrlen = sizeof(struct sockaddr_in);
memset(&server_addr, 0, addrlen);
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
server_addr.sin_port = htons(PORT);
if (setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)) < 0)
{
printf("bind socket error: %s(errno: %d)\n",strerror(errno),errno);
exit(0);
}
if( bind(listenfd, (struct sockaddr*)&server_addr, sizeof(server_addr)) == -1)
{
printf("bind socket error: %s(errno: %d)\n",strerror(errno),errno);
exit(0);
}
if( listen(listenfd, 10) == -1)
{
printf("listen socket error: %s(errno: %d)\n",strerror(errno),errno);
exit(0);
}
printf("wait client accpt \n");
while(1)
{
if( (connetfd = accept(listenfd, (struct sockaddr*)&client_addr, &addrlen)) == -1)
{
printf("accept socket error: %s(errno: %d)",strerror(errno),errno);
continue;
}
/* set NONBLOCK */
flags = fcntl(connetfd, F_GETFL, 0);
fcntl(connetfd, F_SETFL, flags | O_NONBLOCK);
signal(SIGCHLD, SIG_IGN);
pid = fork();
if(pid == -1)
{
printf("fork err \n");
}
if(pid == 0)
{
pid_child = fork();
if(pid_child == 0)
{
pid_send = getpid();
read_func(pid_send, connetfd);
}
else
{
pid_send = getpid();
write_func(pid_send,connetfd);
}
}
}
}

在该程序中，当接收到客户端的一个连接后，将连接描述符设置成非阻塞的：[objc] view plain copy

flags = fcntl(connetfd, F_GETFL, 0);
fcntl(connetfd, F_SETFL, flags | O_NONBLOCK);

这样设置之后，在读和写函数中的send和recv函数都变为了非阻塞模式。在这里我们使用的是sleep来做一个延时循环检测数据可读和数据可发送。在这里常用的套接字超时并不是sleep函数。我们可以使用下面的三种套接字超时方法。

套接字超时：

（1）调用alarm，它在指定超时期满时产生SIGALARM信号，这与Linux信号处理类似。

[objc] view plain copy

static void sig_alrm(int signo)
{
return; /* just interrupt the recvfrom() */
}
void dg_cli(FILEFILE *fp, int sockfd, const SA *pservaddr, socklen_t servlen)
{
int n;
char sendline[MAXLINE], recvline[MAXLINE + 1];
signal(SIGALRM, sig_alrm);
while (Fgets(sendline, MAXLINE, fp) != NULL) {
sendto(sockfd, sendline, strlen(sendline), 0, pservaddr, servlen);
alarm(5);
if ( (n = recvfrom(sockfd, recvline, MAXLINE, 0, NULL, NULL)) < 0) {
if (errno == EINTR)
fprintf(stderr, "socket timeout\n");
else
err_sys("recvfrom error");
} else {
alarm(0);
recvline[n] = 0; /* null terminate */
fputs(recvline, stdout);
}
}
}

（2）在select 中阻塞等待I/O(select 有内置的时间限制)，以此代替直接阻塞在read或write调用上。

[objc] view plain copy

int readable_select(int fd, int sec)
{
fd_set rset;
struct timeval tv;
FD_ZERO(&rset);
FD_SET(fd, &rset);
tv.tv_sec = sec;
tv.tv_usec = 0;
return(select(fd+1, &rset, NULL, NULL, &tv));
/* 4> 0 if descriptor is readable */
}

（3）使用较新的SO_RCVTIMEO和SO_SNDTIMEO套接字选项。

[objc] view plain copy

void dg_cli(FILEFILE *fp, int sockfd, const SA *pservaddr, socklen_t servlen)
{
int n;
char sendline[MAXLINE], recvline[MAXLINE + 1];
struct timeval tv;
tv.tv_sec = 5;
tv.tv_usec = 0;
setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv));
while (fgets(sendline, MAXLINE, fp) != NULL) {
sendto(sockfd, sendline, strlen(sendline), 0, pservaddr, servlen);
n = recvfrom(sockfd, recvline, MAXLINE, 0, NULL, NULL);
if (n < 0) {
if (errno == EWOULDBLOCK) {
fprintf(stderr, "socket timeout\n");
continue;
} else
err_sys("recvfrom error");
}
recvline[n] = 0; /* null terminate */
fputs(recvline, stdout);
}
}

装载：http://blog.csdn.net/li_wen01/article/details/55098317

设置非阻塞socket收发数据相关推荐

iphone开发之轻松搞定原生socket 编程，阻塞与非阻塞，收发自如
iphone socket 开发在iphone的平台下,要进行socket开发其实有很多种的方法,开源的库Asyncsocket,官方的CFSocket,还有BSD的socket. 这里要做一个简单 ...
使用select+非阻塞socket写的网络数据转发程序 « Xiaoxia[PG]
使用select+非阻塞socket写的网络数据转发程序 « Xiaoxia[PG] 使用select+非阻塞socket写的网络数据转发程序 « Xiaoxia[PG] 从实践之中,我又学到东西了! ...
linux下网络编程设置非阻塞,UNIX网络编程非阻塞connect的实现
一.<UNIX网络编程>-非阻塞connect 在一个TCP套接口被设置为非阻塞之后调用connect,connect会立即返回EINPROGRESS错误,表示连接操作正在进行中,但是仍未 ...
socket编程 —— 非阻塞socket (转)---例子已上传至文件中
在上一篇文章 <socket编程--一个简单的例子> http://blog.csdn.net/wind19/archive/2011/01/21/6156339.aspx 中写了一个简单 ...
使用NIO实现异步非阻塞Socket tcp通信
使用NIO实现异步非阻塞Socket tcp通信一.BIO与NIO IO(BIO)和NIO区别:其本质就是阻塞和非阻塞的区别阻塞概念:应用程序在获取网络数据的时候,如果网络传输数据很慢,就会一直等 ...
linux socket 阻塞服务端非阻塞客户端,linux下异步RPC的阶段性总结-非阻塞SOCKET客户端...
尽可能使用非阻塞socket int flags, s; flags = fcntl (fd, F_GETFL, 0); if (flags == -1){ close(fd); return -1; ...
深入理解阻塞socket和非阻塞socket
什么是阻塞socket,什么是非阻塞socket.对于这个问题,我们要先弄清什么是阻塞/非阻塞.阻塞与非阻塞是对一个文件描述符指定的文件或设备的两种工作方式. 阻塞的意思是指,当试图对该文件描述符进行 ...
linux 非阻塞 socket - Google 搜索
linux 非阻塞 socket - Google 搜索 linux c实现超时.非阻塞socket的函数select - Yunlu Liu (刘云璐) sites.google.com/site/ ...
python select實現非阻塞socket
python select實現非阻塞socket - liukeforever的专栏 - 博客频道 - CSDN.NET python select實現非阻塞socket 分类: Python 201 ...

设置非阻塞socket收发数据

设置非阻塞socket收发数据相关推荐

最新文章

热门文章