Чтение и запись файлов с поддержкой iostream socket

Question

Чтение и запись файлов с поддержкой iostream socket

Я пытаюсь отправлять и получать файлы, используя boost iostream сокеты. Каков наиболее эффективный способ прочитать содержимое файла и затем отправить в поток? А как читать этот контент на стороне сервера и записывать в файл?

Послать:

boost::asio::io_service svc;
using boost::asio::ip::tcp;
tcp::iostream sockstream(tcp::resolver::query{ "127.0.0.1", "3780" });

std::ifstream fs;
fs.open("img.jpg", std::ios::binary);
sockstream << // send file to stream

Получать:

boost::asio::io_service ios;

boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::tcp::v4(), 3780);
boost::asio::ip::tcp::acceptor acceptor(ios, endpoint);

for (;;)
{
boost::asio::ip::tcp::iostream stream;
boost::system::error_code ec;
acceptor.accept(*stream.rdbuf(), ec);

if (!ec) {
std::ofstream of;
of.open("rcv.jpg", std::ios::binary);

// read the file content with stream
// write content to file
}
}

3

boost c++

Решение

Другие решения

Других решений пока нет …

Источник

Accepted Answer

Я заполнил недостающие части из примера документации:

http://www.boost.org/doc/libs/1_62_0/doc/html/boost_asio/example/cpp03/iostreams/daytime_server.cpp

Вот простая программа отправителя / получателя, которая (я думаю) делает то, что вы ожидаете:

Жить на Колиру

#include <boost/iostreams/filtering_stream.hpp>
#include <boost/iostreams/filter/gzip.hpp>
#include <boost/iostreams/copy.hpp>
#include <boost/asio.hpp>
#include <iostream>
#include <fstream>
using boost::asio::ip::tcp;

void sender() {
boost::asio::io_service svc;

tcp::iostream sockstream(tcp::resolver::query { "127.0.0.1", "6768" });

boost::iostreams::filtering_ostream out;
out.push(boost::iostreams::zlib_compressor());
out.push(sockstream);

{
std::ifstream ifs("main.cpp", std::ios::binary); // pretend this is your JPEG
out << ifs.rdbuf();
out.flush();
}
}

void receiver() {

int counter = 0;
try
{
boost::asio::io_service io_service;

tcp::endpoint endpoint(tcp::v4(), 6768);
tcp::acceptor acceptor(io_service, endpoint);

for (;;)
{
tcp::iostream stream;
boost::system::error_code ec;
acceptor.accept(*stream.rdbuf(), ec);

{
boost::iostreams::filtering_istream in;
in.push(boost::iostreams::zlib_decompressor());
in.push(stream);

std::ofstream jpg("test" + std::to_string(counter++) + ".out", std::ios::binary);
copy(in, jpg);
}

// break; // just for shorter demo
}
}
catch (std::exception& e)
{
std::cerr << e.what() << std::endl;
exit(255);
}
}

int main(int argc, char**argv) {
if (--argc && argv[1]==std::string("sender"))
sender();
else
receiver();
}

Когда вы запускаете приемник:

./test

И использовать отправителя несколько раз:

./test sender

Получатель распакует и запишет полученный файл в test0.out, test1.out и т. Д.

3