Network Library

				
					#include <boost/asio.hpp>
#include <iostream>
#include <string>

using namespace boost::asio;

// Function to handle incoming connections
void handle_connection(io_context& io_context, ip::tcp::socket socket) {
  while (true) {
    // Buffer to receive data from client
    boost::asio::streambuf buffer;

    // Read data from the socket until a newline character is received
    read_until(socket, buffer, "\n");

    // Convert received data to string
    std::string message = buffer.data();

    // Echo the message back to the client
    write(socket, buffer_cast<const char*>(message));

    // Check if the client has sent a "quit" message
    if (message == "quit\n") {
      break;
    }
  }

  // Close the socket
  socket.close();
}

int main() {
  try {
    // Create an I/O context
    io_context io_context;

    // Create a TCP endpoint (port 12345)
    ip::tcp::endpoint endpoint(ip::address::from_string("localhost"), 12345);

    // Create a TCP acceptor object
    ip::tcp::acceptor acceptor(io_context, endpoint);

    std::cout << "Server listening on port 12345..." << std::endl;

    while (true) {
      // Wait for a new connection
      ip::tcp::socket socket(io_context);
      acceptor.accept(socket);

      std::cout << "Client connected!" << std::endl;

      // Handle the connection in a separate thread for concurrency
      std::thread worker_thread(handle_connection, std::ref(io_context), std::move(socket));
      worker_thread.detach(); // Detach the thread to avoid resource leaks
    }
  } catch (std::exception& e) {
    std::cerr << "Error: " << e.what() << std::endl;
  }

  return 0;
}