c++ - 使用套接字编程的c++中的stringstream vs ifstream(ofstream)

Question

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

• (省略绑定(bind)等)

  1. 客户端进程有字符串

  2. 保存到文件

  3. 然后通过首先将文件读入流将文件发送到服务器

  4. 服务器接收流并将其写入另一个文件。

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

Answer 1

您的原始问题:

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

我的初步 react :

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 */
}