分布式对象存储 读书笔记

todo

 

差不多看到第二章 环境和代码编译验证 已经确认到了第四章节

全书能正常编译测试执行完毕应该是没问题了，剩下的就是消化吸收的问题了

近日开始着手编写验证日志 读书笔记 

该书籍使用的GO语言作为示例

经过验证 windows下运行curl  rabbitmq ElasticSearch 等软件都是OK的 那么就可以在windows下使用c++来进行学习 VS的调试当然更顺手

如果时间允许的话 也许也会使用c++重写分布式对象存储实验代码

留一段代码 以后改写C++就靠这个实现http了

// DelMe.cpp : 此文件包含 "main" 函数。程序执行将在此处开始并结束。
//

#include "pch.h"
#include <iostream>
#include <cstdlib>
#include <iostream>
#include <thread>
#include <string>
#include <utility>
#include <boost/asio.hpp>

using boost::asio::ip::tcp;

const int max_length = 1024;

void session(tcp::socket sock)
{
    try
    {
        for (;;)
        {
            char data[max_length];

            boost::system::error_code error;
            size_t length = sock.read_some(boost::asio::buffer(data), error);
            data[max_length - 1] = '';
            for (int i = 0; i < max_length; i++) {
                if (data[i] != '')
                    std::cout << data[i];
            }
            std::cout << std::endl;

            if (error == boost::asio::error::eof)
                break; // Connection closed cleanly by peer.
            else if (error)
                throw boost::system::system_error(error); // Some other error.
            std::string s = "HTTP/1.0 200 OK
Server: def
Accept-Ranges: bytes
Content-Length: 0
Connection: Keep-Alive
Content-Type: text/plain

111";
            boost::asio::write(sock, boost::asio::buffer(s, s.size()));
        }
    }
    catch (std::exception& e)
    {
        std::cerr << "Exception in thread: " << e.what() << "
";
    }
}

void server(boost::asio::io_context& io_context, unsigned short port)
{
    tcp::acceptor a(io_context, tcp::endpoint(tcp::v4(), port));
    for (;;)
    {
        std::thread(session, a.accept()).detach();
    }
}

int main(int argc, char* argv[])
{
    try
    {
        boost::asio::io_context io_context;

        server(io_context, std::atoi("9923"));
    }
    catch (std::exception& e)
    {
        std::cerr << "Exception: " << e.what() << "
";
    }

    return 0;
}