Internet Protocol
Header Only Library

TCP Server

How to use TCP server class

References

#include "IP/InternetProtocol.hpp"

Syntax

namespace InternetProtocol
class TCPServer

Example code

#include <iostream>
#include <IP/TCP/TCPServer.hpp>
 
using namespace InternetProtocol;
 
int main()
{
    TCPServer server;
    server.set_socket(EProtocolType::V4, 3000);
    server.on_message_received = [&](const FTcpMessage message, const socket_ptr& socket) {
        std::cout << socket->remote_endpoint().port() << " -> " << buffer_to_string(message.raw_data) << std::endl;
    };
    server.open();
 
    std::string input;
    std::cout << "Digite algo: ";
    while (std::getline(std::cin, input)) {
        if (input == "quit")
        {
            server.close();
            break;
        }
    }
    return 0;
}

Variables

FTcpMessage

namespace InternetProtocol
 
struct FTcpMessage {
    std::vector<std::byte> raw_data;
    size_t size = 0;
};

Functions

Set Socket

  • Set the adress, port, max connection of socket acceptor
void set_socket(const EProtocolType protocol, const uint16_t port, const int max_listen_conn = 2147483647)

Get Acceptor

  • Get socket acceptor
asio::ip::tcp::acceptor &get_acceptor()

Get Sockets

  • Get all sockets connected to the server
const std::set<socket_ptr> get_sockets() const

Set Max Send Buffer Size

  • Set max size in bytes of send buffer
void set_max_send_buffer_size(int value = 1400)

Get Max Send Buffer Size

  • Get max size in bytes of send buffer
int get_max_send_buffer_size() const

Set Split Package

  • If the size of a message exceeds the maximum allowed size for the send buffer, it will be divided into smaller packets before being sent.
void set_split_package(bool value = true)

Get Split Package

  • Get if Split Package is enabled
bool get_split_package() const

Send Str To

  • Send a string message
  • Return false if message is empty or socket is closed
  • Warning: If you’re using Windows, ensure that you are sending characters compatible with UTF-8
bool send_str_to(const std::string &message, const socket_ptr &socket)

Send Buffer To

  • Send a buffer message
  • Return false if message is empty or socket is closed
bool send_buffer_to(const std::vector<uint8_t> &buffer, const socket_ptr &socket)

Open

  • Open connection
  • Return false if socket is already open or any error occurs
  • Event on_error is triggered if any error occurs
bool open()

Close

  • Disconnect all clients and close connection
void close()

Disconnect Socket

  • Close connection of specific socket
void disconnect_socket(const socket_ptr &socket)

Get Error Code

  • Get latest error code
int get_error_code() const

Events

On Socket Accepted

  • Event triggered when a new client connection is estabilished
std::function<void(const socket_ptr &)> on_socket_accepted

On Bytes Transferred

  • Event triggered when socket send or receive data
  • size_t: bytes sent
  • size_t: bytes received
std::function<void(const size_t, const size_t)> on_bytes_transfered

On Message Sent

  • Event triggered when a message is sent by specific socket
  • const asio::error_code &: if error occur, error code will be different from 0
std::function<void(const asio::error_code &, const socket_ptr &)> on_message_sent

On Message Received

  • Event triggered when a message is received by specific socket
  • FTcpMessage: message struct
  • Use buffer_to_string() function to converte raw_data to std::string
std::function<void(const FTcpMessage, const socket_ptr &)> on_message_received

On Socket Disconnected

  • Event triggered when a socket is diconnected
  • const asio::error_code &: if error occur, error code will be different from 0
  • Normally, when an error occurs, the socket is automatically closed, triggering the on_close event.
std::function<void(const asio::error_code &, const socket_ptr &)> on_socket_disconnected

On Close

  • Event triggered when socket and acceptor is closed
std::function<void()> on_close

On Error

  • Event triggered if any error occur during async process
  • const asio::error_code &: if error occur, error code will be different from 0
std::function<void(const asio::error_code &)> on_error