c++基于asio的组播:windows linux通信

Posted 2021-07-15 qianbo_insist

上代码，非常简单，使用参数控制发送和接收

#define _CRT_SECURE_NO_WARNINGS
#include <iostream>

// 3rd party includes.
#include <asio.hpp>
#include <string>
#include <thread>
using namespace std;
using namespace asio::ip;
void read(asio::ip::udp::socket& socket)
{
	asio::ip::udp::endpoint sender;
	std::vector<char> buffer;
	std::size_t bytes_readable = 0;
	for (;;)
	{
		// Poll until data is available.
		while (!bytes_readable)
		{
			// Issue command to socket to get number of bytes readable.
			asio::socket_base::bytes_readable num_of_bytes_readable(true);
			socket.io_control(num_of_bytes_readable);

			// Get the value from the command.
			bytes_readable = num_of_bytes_readable.get();

			// If there is no data available, then sleep.
			if (!bytes_readable)
			{
				std::this_thread::sleep_for(std::chrono::milliseconds(200));
				//boost::this_thread::sleep(boost::posix_time::seconds(1));
			}
		}

		// Resize the buffer to store all available data.
		buffer.resize(bytes_readable);

		// Read available data.
		socket.receive_from(
			asio::buffer(buffer, bytes_readable),
			sender);

		// Extract data from the buffer.
		std::string message(buffer.begin(), buffer.end());

		// Output data.
		std::cout << "Received message:\\n";
		std::cout << message << std::endl;
	}
}

void write(asio::ip::udp::socket& socket,
	asio::ip::udp::endpoint& destination)
{
	//std::string message;

	//char buffer[256];
	//sprintf(buffer, msearchmsgfmt, "upnp:rootdevice");
	/*socket.async_send_to(
		boost::asio::buffer(buffer, strlen(buffer)), endpoint_,
		boost::bind(handle_send_to, this,
			boost::asio::placeholders::error));*/

	for (unsigned int i = 0; i < 300; ++i)
	{
		//std::ostringstream stream;
		//stream << i;
		//message = stream.str();
		char buffer[256];
		sprintf(buffer, "this is test %d", i);
		std::cout << "Sent message ok->" << ""<< std::endl;
		socket.send_to(asio::buffer(buffer, strlen(buffer)), destination);
		std::this_thread::sleep_for(std::chrono::milliseconds(5000));
	}
}




int main(int argc, char* argv[])
{
    // Extract command-line arguments.
	bool receiver = true;
	string addr = "234.0.0.1";
	if (argc < 2)
	{
		receiver = true;
	}
	else
		receiver = std::string(argv[1]) == "s" ? false : true;

	asio::ip::address address =
        asio::ip::address::from_string(addr);
    unsigned short port = 1900;  //boost::lexical_cast<unsigned short>(1900);
	asio::ip::address local =
		asio::ip::address::from_string("0.0.0.0");
	//unsigned short localport = 50000;
    // Create socket.
    asio::io_context service;
    udp::socket socket(service);

	
    socket.open(asio::ip::udp::v4());

    socket.set_option(udp::socket::reuse_address(true));

   
    //socket.set_option(asio::ip::multicast::enable_loopback(true));
    socket.bind(
        udp::endpoint(asio::ip::address_v4::any(),
            receiver ? port : 16200));

	//socket.bind(
	//	udp::endpoint(local,1900));


    udp::endpoint destination(address, port);

    // Join group.
    socket.set_option(asio::ip::multicast::join_group(address));

    // Start read or write loops based on command line options.
	//std::thread t([](){
	//	printf("this is a test");
	//}); // pass by reference
	
	if (receiver)
		read(socket);
	else
		write(socket,destination);
	//std::thread t(read, std::ref(socket)); // pass by reference
    //write(socket, destination);
    return 0;
}

编译

g++ -std=c++11 main.cpp -o out -lpthread -I./include
由于使用了c++11 线程所以使用c++11 编译，线程必须加上 -lpthread 参数， 使用asio，
所以includ 是asio的include头文件
linux 下执行
./out
没有参数则表示接收，开始执行接收

windows下编译使用vs，加上一个参数

-s 参数表示发送
windows下CTRL+F5执行

执行结果

window程序开始发送
linux程序开始接收