boost asio example
// ./boost_1_81_0/doc/html/boost_asio/example/cpp11/echo/async_tcp_echo_server.cpp
// ./boost_1_81_0/doc/html/boost_asio/example/cpp11/timeouts/async_tcp_client.cpp
$ cd boost_1_81_0
$ ./bootstrap.sh
$ ./b2
The Boost C++ Libraries were successfully built!
The following directory should be added to compiler include paths:
/home/ljh/Downloads/boost_1_81_0
The following directory should be added to linker library paths:
/home/ljh/Downloads/boost_1_81_0/stage/lib
$
# or,
$ apt install libboost-dev
---
// src/Makefile
SUBDIRS = main # foo
all : $(SUBDIRS)
# main : foo
install : $(SUBDIRS)
define versioning # version soversion
$(MAKE) -C $@ soversion=lib$@.so.$(2)
@ cp $@/$@ $@/lib$@.so.$(1)
@ cd $@; ln -f -s lib$@.so.$(1) lib$@.so.$(2); cd ..
@ cd $@; ln -f -s lib$@.so.$(1) lib$@.so; cd ..
endef
# foo :
# $(call versioning,1.2.3,1.2) #,version,soversion
main :
$(MAKE) -C $@
# make -C src/ DESTDIR=~/foo install
install :
install -d "$(DESTDIR)/usr/local/bin"
# install -d "$(DESTDIR)/usr/local/lib"
install -m0755 main/main "$(DESTDIR)/usr/local/bin"
# install -m0755 foo/*.so foo/*.so.* "$(DESTDIR)/usr/local/lib"
clean :
for dir in $(SUBDIRS); do \
$(MAKE) -C $$dir $@; \
done
.PHONY : $(SUBDIRS) all clean install
---
// src/main/Makefile
# build shared library with -fPIC, -shared
CXXFLAGS = # -g -O3 -fPIC # CXXFLAGS for .cpp
CPPFLAGS = #-MMD -MP -I../foo
LDFLAGS = # -L../foo -Wl,-rpath,'$$ORIGIN/../foo' # -shared
LDLIBS = -lpthread
CC = $(CXX) # link with CXX for .cpp
CPPFLAGS += -I/home/ljh/Downloads/boost_1_81_0
LDFLAGS += -L/home/ljh/Downloads/boost_1_81_0/stage/lib
# make # NDEBUG=1
ifdef NDEBUG
CPPFLAGS += -DNDEBUG
CXXFLAGS += -O3 # .cpp
else
CXXFLAGS += -g # .cpp
LDFLAGS += -fsanitize=address
endif
all: server client
# target name is basename of one of the source files
# main : $(patsubst %.c,%.o,$(wildcard *.c)) # .cpp
server : $(patsubst %.cpp,%.o,server.cpp) # .cpp
client : $(patsubst %.cpp,%.o,client.cpp) # .cpp
-include *.d
clean : ; -rm -fr *.o *.d server client
.PHONY : clean
---
// src/main/server.cpp
// ./boost_1_81_0/doc/html/boost_asio/example/cpp11/echo/async_tcp_echo_server.cpp
#include <cstdlib>
#include <iostream>
#include <memory>
#include <utility>
#include <boost/asio.hpp>
#include <sanitizer/lsan_interface.h>
struct session
: public std::enable_shared_from_this<session>
{
session(boost::asio::ip::tcp::socket socket)
: socket(std::move(socket))
{ }
void start() {
start_read();
start_write();
}
void start_read() {
auto self(shared_from_this());
memset(input_data, 0, sizeof(input_data));
socket.async_read_some(
boost::asio::buffer(input_data, sizeof(input_data)),
[&, self](boost::system::error_code ec, std::size_t length) {
if (!ec) {
std::cout << input_data;
start_read();
} else {
std::cout << ec.message() << "\n";
}
}
);
}
void start_write() {
auto self(shared_from_this());
memset(output_data, 0, sizeof(output_data));
snprintf(output_data, sizeof(output_data) - 1,
"hello client %zu\n", cnt++);
boost::asio::async_write(
socket,
boost::asio::buffer(output_data, sizeof(input_data)),
[&, self](boost::system::error_code ec, std::size_t length)
{
if (!ec) {
// sleep(1); //test
start_write();
} else {
std::cout << ec.message() << "\n";
}
}
);
}
boost::asio::ip::tcp::socket socket;
enum { LEN = 1024 };
char input_data[LEN];
char output_data[LEN];
size_t cnt = 0;
};
struct server {
server(boost::asio::io_context& io_context, short port)
: acceptor(io_context, boost::asio::ip::tcp::endpoint(
boost::asio::ip::tcp::v4(), port))
{
std::cout << "Listen on port: " << port << " \n";
do_accept();
}
void do_accept() {
acceptor.async_accept(
[&](boost::system::error_code ec,
boost::asio::ip::tcp::socket socket)
{
if (!ec) {
std::cout << "Accept connection: "
<< socket.remote_endpoint() << "\n";
std::make_shared<session>(std::move(socket))->start();
} else {
std::cout << ec.message() << "\n";
}
do_accept();
}
);
}
boost::asio::ip::tcp::acceptor acceptor;
};
void handlerCont(int signum) {
printf("SIGCONT %d\n", signum);
#ifndef NDEBUG
__lsan_do_recoverable_leak_check();
#endif
}
int main(int argc, char* argv[]) {
if (argc != 2) {
std::cerr << "Usage: server <port>\n";
return 1;
}
signal(SIGCONT, handlerCont); // $ man 7 signal
boost::asio::io_context io_context;
server s(io_context, std::atoi(argv[1]));
io_context.run();
return 0;
}
---
// src/main/client.cpp
// ./boost_1_81_0/doc/html/boost_asio/example/cpp11/timeouts/async_tcp_client.cpp
#include <boost/asio/buffer.hpp>
#include <boost/asio/io_context.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <boost/asio/write.hpp>
#include <iostream>
#include <string>
#include <sanitizer/lsan_interface.h>
std::string client_tag; //test
struct session
: public std::enable_shared_from_this<session>
{
session(boost::asio::ip::tcp::socket socket)
: socket(std::move(socket))
{ }
void start() {
start_read();
start_write();
}
void start_read() {
auto self(shared_from_this());
memset(input_data, 0, sizeof(input_data));
socket.async_read_some(
boost::asio::buffer(input_data, sizeof(input_data)),
[&, self](boost::system::error_code ec, std::size_t length) {
if (!ec) {
std::cout << input_data;
start_read();
} else {
std::cout << ec.message() << "\n";
}
}
);
}
void start_write() {
auto self(shared_from_this());
memset(output_data, 0, sizeof(output_data));
snprintf(output_data, sizeof(output_data) - 1,
"hello server %s %zu\n", client_tag.c_str(), cnt++);
boost::asio::async_write(
socket,
boost::asio::buffer(output_data, sizeof(input_data)),
[&, self](boost::system::error_code ec, std::size_t length)
{
if (!ec) {
// sleep(1); //test
start_write();
} else {
std::cout << ec.message() << "\n";
}
}
);
}
boost::asio::ip::tcp::socket socket;
enum { LEN = 1024 };
char input_data[LEN];
char output_data[LEN];
size_t cnt = 0;
};
struct client {
client(boost::asio::io_context& io_context,
boost::asio::ip::tcp::resolver::results_type endpoints)
: socket(io_context), endpoints(endpoints)
{
do_connect(endpoints.begin());
}
void do_connect (
boost::asio::ip::tcp::resolver::results_type::iterator
endpoint_iter)
{
if (endpoint_iter != endpoints.end()) {
socket.async_connect(
endpoint_iter->endpoint(),
[&](const boost::system::error_code ec)
{
if (!socket.is_open()) {
std::cout << "Connect timed out\n";
do_connect(++endpoint_iter);
} else if (ec) {
std::cout << "Connect error: " << ec.message() << "\n";
socket.close();
} else {
std::cout << "Connected to " <<
socket.remote_endpoint() << "\n";
std::make_shared<session>(std::move(socket))->start();
}
}
);
}
}
boost::asio::ip::tcp::resolver::results_type endpoints;
boost::asio::ip::tcp::socket socket;
};
void handlerCont(int signum){
printf("SIGCONT %d\n", signum);
#ifndef NDEBUG
__lsan_do_recoverable_leak_check();
#endif
}
int main(int argc, char* argv[]) {
if (argc != 4) {
std::cerr << "Usage: client <host> <port> <tag>\n";
return 1;
}
signal(SIGCONT, handlerCont); // $ man 7 signal
client_tag = argv[3];
boost::asio::io_context io_context;
boost::asio::ip::tcp::resolver r(io_context);
client c(io_context, r.resolve(argv[1], argv[2]));
io_context.run();
return 0;
}
