Linux C++ 回射服务器

http://blog.csdn.net/qq_25425023/article/details/53914820

回射服务器就是服务端将客户端的数据发送回去。

我实现的回射服务器返回增加了时间。

服务端代码，可以很容易看懂：

[cpp] view plain copy

#include <sys/socket.h>
#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <time.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include "../thread_pool.h" //在上一篇博客中
#define MAX_BUFFER 512
typedef struct sockaddr SSA;
char timebuffer[50]; //存储时间
char readbuffer[MAX_BUFFER]; //存储客户端数据
time_t tick;
//任务类
class task
{
private:
int connfd; //与客户端连接的文件描述符
public:
task(int conn) : connfd(conn)
{
}
~task(){}
void doit() //线程池调用函数
{
size_t readsize;
while((readsize = read(connfd, readbuffer, MAX_BUFFER)) > 0) //读取客户端数据
{
printf("%ld get %dbyte\n",(unsigned long)pthread_self()
, (int)readsize); //测试用
if(readsize == -1) //read出错
{
printf("errno is %s\n", strerror(errno)); //这里输出"onnection reset by peer"
continue;
}
readbuffer[readsize] = '\0';
tick = time(NULL); //获取时间
snprintf(timebuffer, sizeof(timebuffer), "time : %.24s\r\n",
ctime(&tick));
strcat(readbuffer, timebuffer); //时间与客户数据连接到一起
write(connfd, readbuffer, strlen(readbuffer)); //发送给客户端
}
// printf("close the connfd\n");
// fflush(stdout);
close(connfd);
}
};
int main(int argc, char *argv[])
{
if(argc != 2)
{
printf("uasge : %s port", argv[0]);
exit(-1);
}
int sockfd, connfd;
struct sockaddr_in serv_addr, cli_addr;
int port = atoi(argv[1]);
//初始化sockaddr_in
serv_addr.sin_family = AF_INET;
serv_addr.sin_port = htons(port);
serv_addr.sin_addr.s_addr = htonl(INADDR_ANY); //允许任何人连接
//创建套接字
sockfd = socket(AF_INET, SOCK_STREAM, 0);
if(sockfd < 0)
{
printf("socket error' n");
exit(-1);
}
//绑定
bind(sockfd, (SSA *)&serv_addr, sizeof(serv_addr));
//监听套接字
listen(sockfd, 6);
//创建线程池
threadpool<task> pool(60, 100);
pool.start(); //开启线程池
while(1)
{
socklen_t len = sizeof(cli_addr);
connfd = accept(sockfd, (SSA *)&cli_addr, &len); //接受连接
task *ta = new task(connfd); //新建任务
char buf[20];
printf("IP %s conn\n", inet_ntop(AF_INET, &cli_addr.sin_addr, buf,
sizeof(buf)));
while(!pool.append_task(ta)) //添加任务到任务队列
printf("loop\n"); //测试用
}
return 0;
}

下面的是客户端的代码：

[cpp] view plain copy

#include <stdio.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <string.h>
#include <sys/types.h>
#include <unistd.h>
#include <netinet/in.h>
#include <stdlib.h>
int main(int argc, char *argv[])
{
if(argc != 3) //参数不对，退出
{
printf("usage: %s ip port\n", argv[0]);
exit(-1);
}
int sockfd;
struct sockaddr_in serv_addr;
int port = atoi(argv[2]); //将字符串的端口转换称int
//初始化服务端的端口和IP地址
serv_addr.sin_family = AF_INET;
serv_addr.sin_port = htons(port); //将主机字节序转换称网络字节序
inet_pton(AF_INET, argv[1], &serv_addr.sin_addr);
//创建套接字
sockfd = socket(AF_INET, SOCK_STREAM, 0);
//连接
connect(sockfd, (struct sockaddr *)&serv_addr,
sizeof(serv_addr));
char buffer[50];
write(sockfd, "hello\n", 6); //写数据
shutdown(sockfd, SHUT_WR); //解释在下面
size_t num = read(sockfd, buffer, sizeof(buffer)); //读数据
buffer[num] = '\0';
printf("read: %s\n", buffer);
shutdown(sockfd, SHUT_RD);
// close(sockfd);
return 0;
}

客户端一开始我使用的是最后来个close的，就是注释那部分，但是多个连接同时来的时候，服务端会出错，具体的出错信息是：Connection reset by peer，重新执行read之后，得到Hello的个数没有少，也就是客户端发送的个数。

然而我客户端写完数据，就关闭写端，读取完数据，再关闭读端，就不会出现这样的错误。

具体原因还不是很清楚，网上没有查找到具体的答案。求大神来解答！！~~

==============================================

终于知道原因了，出错的是在服务端的read函数，read返回-1，而在客户端，发送完数据，就shutdown写端，发送完数据，就会发送FIN包，服务端read返回0，因为read不止被调用一次，第一次读取完数据之后，继续读取，可是客户端没有数据可读，就会出错，而提前关闭客户端写端，所以read那里的WHILE退出，就没有了出错的信息。

同时写了两个shell文件来测试:

[html] view plain copy

#!/bin/bash
for i in `seq 2000`
do
./client.out 127.0.0.1 8989
done

循环执行2000次。

第二个shell文件：

[html] view plain copy

#!/bin/bash
./loop.sh > file1 &
./loop.sh > file2 &
./loop.sh > file3 &
./loop.sh > file4 &
./loop.sh > file5 &
wait

开启5个进程来返问。

执行第二个shell文件

最终，耗时为：

[html] view plain copy

real 0m7.589s
user 0m0.460s
sys 0m1.944s

而且五个File文件中，有Hello的行数数都为2000.

下一篇是实现一个简单小型的web服务器。

Linux C++ 回射服务器相关推荐

linux——回射服务器
回射服务器即客户端发送一段数据给服务器,服务器再将这段数据原封不动的发送给客户端,原理很简单,原理图如下: 以TCP协议为例,客户端.服务器代码如下: ** 服务器: ** #include < ...
LIBUV学习笔记（三）libuv中pipe/tty相关操作以及一个简单的unix域回射服务器/客户端例子...
uv_pipe_t - Pipe handle Pipe handles provide an abstraction over local domain sockets on Unix and na ...
《UNP》随笔——“实现一个简单的回射服务器”存在的不足(信号处理)
尽管实现了一个简单的回射服务器,但依旧存在一些不足: 服务端的子进程结束的时候,由于父进程未对子进程发送的SIGCHLD信号进行处理,会导致子进程进入僵死状态.这一点该如何解决? 客户端A向服务端B发 ...
一个简单的回射服务器
本文编写了一个初步的简单的回射服务器例子.基本内容书上都能找到,认真看书就行了,所以尽量讲一些自己认为应该注意的地方. 功能: 客户端从标准输入读入一行文本,写给服务器:服务器读入这行文本,并回射给客 ...
TCP echo_server(C++)回射服务器实现以及问题记录
TCP echo_server(C++)回射服务器实现以及问题记录基本运行方式: 客户端接收用户输入的字符串并发送到服务器端服务器端将接收的字符串数据传回客户端服务器端和客户端之间的字符串回射一 ...
UNIX TCP回射服务器/客户端之使用epoll模型的服务器
程序简介:这是一个运用epoll系列函数进行IO复用的服务器模型.它是目前UNIX与LINUX平台上效率最高,最受欢迎的IO复用传输模型. 其他的不说了,直接粘贴代码吧! 服务器端: #include ...
Linux——回射服务器多并发（多线程）
多线程与多进程的做法区别不大,思路一样,都是执行两个死循环,一个循环等待客户端连接,一个循环与客户端通信.多进程的方式请点此处服务器 #include <sys/socket.h> #i ...
linux——回射服务器多并发（多进程）
多并发原理如图,多个客户端连接一个服务器,无论哪个客户端发送数据给服务器,服务器都能把数据准确的返回给这个客户端. 在socket编程中,socket这种文件描述符被默认设置为阻塞,故而read函数和 ...
Linux非阻塞IO（八）使用epoll重新实现非阻塞的回射服务器
2019独角兽企业重金招聘Python工程师标准>>> 本文无太多内容,主要是几个前面提到过的注意点: 一是epoll的fd需要重新装填.我们将tcp_connection_t的指针 ...

Linux C++ 回射服务器

Linux C++ 回射服务器相关推荐

最新文章

热门文章