首页 > 解决方案 > 使用套接字编程的c ++中的stringstream vs ifstream(ofstream)

问题描述

我有一个关于 C++ 中的套接字编程的问题。我在网上找到的大多数教程都假设

那么,我的问题是,如果我们可以在步骤 2 中使用 stringstrem 而不是另存为文件呢?文件 I/O(在 C++ 中通常使用 ifstream 和 ofstream)通常很慢。如果我使用 stringstream 目录会更有效吗?

标签: c++network-programmingifstreamstringstream

解决方案


您的原始问题:

“如果我们可以在第 2 步使用 stringstrem 而不是另存为文件呢?”

我的初步反应:

stringstream 与服务器套接字和 IO 文件无关。

您缺乏 IO 操作的基本概念,即 IO 设备文件的概念。没有办法。您在逻辑文件流中不保存任何内容。您的文件字节临时缓冲在您的内存中并刷新。

stringstream 是一个不错的 C++ 库实用程序,可让您将字符串视为文件流。就像您在字节后从输入文件流中读取字节直到 EOF/其他错误,或者在字节后写入输出文件流一样,使用 stringstream 您可以像对待文件流一样对待您的字符串。当您想将字符串划分为小的逻辑单元时,这非常有用。例如,假设您读取一个字符串行,并希望通过将字符串行视为单词流来读取该行中的每个单词。

指导您正确方向的进一步说明:

逻辑文件流中没有“保存”任何内容。每个 I/O 操作都是通过任何计算机系统中的“逻辑”文件执行的。Socket连接两端有两个文件描述符:一个是客户端文件描述符,另一个是服务器文件描述符(连接文件描述符)。服务器通过侦听文件描述符侦听连接请求,该文件描述符实际上与服务器的生命周期一样长,当它接受连接请求时,它通过称为连接文件描述符的接受函数返回另一个文件描述符,该文件描述符一直存在客户端-服务器连接/事务正在进行中。

int accept(int listenfd, struct sockaddr *addr, int *addrlen);

如果您想读取或写入文件流并且还希望缓冲文件字节,那么您确实需要这样做 - 缓冲您的字节。这在服务器和短计数的情况下也非常重要,因为您的连接可能会超时或被信号中断。您可以实施多种选项和技术。但是,在这个小线程中不可能进行这样的讨论。根据您的问题,我要做的是给您一个示例,说明如何通过以下步骤缓冲文件流、避免短计数和处理信号中断:

例如,下面是一个读取 n 个字节并且不缓冲的函数

ssize_t rio_readn(int fd, void *usrbuf, size_t n)
{
size_t nleft = n;
ssize_t nread;
char *bufp = usrbuf;

while (nleft > 0) {
if ((nread = read(fd, bufp, nleft)) < 0) {
if (errno == EINTR) /* Interrupted by sig handler return */
nread = 0;/* and call read() again */
else
return -1;/* errno set by read() */
}
else if (nread == 0)
break;/* EOF */
nleft -= nread;
bufp += nread;
}
return (n - nleft);/* Return >= 0 */
}

我们可以执行以下步骤来执行缓冲和健壮的 IO 操作(注意 RIO 表示健壮的 IO):

第 1 步:设置空的读取缓冲区并关联一个打开的文件描述符,以便我们可以实现我们强大的 IO 操作

#define RIO_BUFSIZE 8192
typedef struct {
int rio_fd;/* Descriptor for this internal buf */
int rio_cnt;/* Unread bytes in internal buf */
char *rio_bufptr;/* Next unread byte in internal buf */
char rio_buf[RIO_BUFSIZE]; /* Internal buffer */
} rio_t;

//初始化健壮的IO缓冲区

void rio_readinitb(rio_t *rp, int fd)
{
rp->rio_fd = fd;
rp->rio_cnt = 0;
rp->rio_bufptr = rp->rio_buf;
}

第 2 步:一个强大的读取实用程序函数来处理短计数

static ssize_t rio_read(rio_t *rp, char *usrbuf, size_t n)
{
int cnt;

while (rp->rio_cnt <= 0) {/* Refill if buf is empty */
rp->rio_cnt = read(rp->rio_fd, rp->rio_buf,
sizeof(rp->rio_buf));
if (rp->rio_cnt < 0) {
if (errno != EINTR) /* Interrupted by sig handler return */
return -1;
}
else if (rp->rio_cnt == 0)/* EOF */
return 0;
else
rp->rio_bufptr = rp->rio_buf; /* Reset buffer ptr */
}

/* Copy min(n, rp->rio_cnt) bytes from internal buf to user buf */
cnt = n;
if (rp->rio_cnt < n)
cnt = rp->rio_cnt;
memcpy(usrbuf, rp->rio_bufptr, cnt);
rp->rio_bufptr += cnt;
rp->rio_cnt -= cnt;
return cnt;
}

第 3 步:用于缓冲读取的强大 IO 功能

ssize_t rio_readnb(rio_t *rp, void *usrbuf, size_t n)
{
size_t nleft = n;
ssize_t nread;
char *bufp = usrbuf;

while (nleft > 0) {
if ((nread = rio_read(rp, bufp, nleft)) < 0) {
if (errno == EINTR) /* Interrupted by sig handler return */
nread = 0;/* Call read() again */
else
return -1;/* errno set by read() */
}
else if (nread == 0)
break;/* EOF */
nleft -= nread;
bufp += nread;
}
return (n - nleft);/* Return >= 0 */
}

推荐阅读