Boost_udp错误

时间:2023-12-17 15:05:02

 

注意一点:当我们不同PC机间进行通信的时候,IP和端口号是不一样的。之前遇到的问题是,boost_system_error,这是因为我们在写程序的时候,发送和接收绑定了同一个端口,导致程序出错。

而且,CANET支持组播通信,也就是说,一个通道可以同时向多个端口发送数据。

 

之前一直搞错的原因就是端口重复绑定了,导致错误。

Boost_udp错误

  1. /*
  2. * Copyright (c) 2015,北京智行者科技有限公司
  3. * All rights reserved.
  4. *
  5. * 文件名称:Boost_UDP.h
  6. * 文件标识:见软件框架协议
  7. * 摘 要:UDP读写类
  8. *
  9. * 当前版本:1.0
  10. * 作 者:zhuxuekui
  11. * 完成日期:2015年11月30日
  12. * 修 改:
  13. *
  14. * 取代版本:1.0
  15. * 原作者 :zhuxuekui
  16. * 完成日期:2015年11月30日
  17. */
  18. #ifndef BOOST_UDP_H
  19. #define BOOST_UDP_H
  20. #include "Utils.h"
  21. using
    namespace boost;
  22. #define RECVSIZE 1024
  23. class Boost_UDP
  24. {
  25. public:
  26.    Boost_UDP(boost::asio::io_service &io_service,string pcIP, int pcPort, string canetIP, int canetPort):udp_sock(io_service)
  27.    {
  28.        m_canetIP = canetIP;
  29.       m_canetPort = canetPort;
  30.       m_pcIP = pcIP;
  31.       m_pcPort = pcPort;
  32.    }
  33.    ~Boost_UDP()
  34.    {
  35.       udp_sock.close();
  36.    }
  37.    //开始socket,绑定端口等。 绑定PC机端口号,而且还不能用 127.0.0.1, 不然会出错,很奇怪的原因。
  38.    void start_sock()
  39.    {
  40.       // here the ip can change to 192.168.1.33
  41.        boost::asio::ip::udp::endpoint local_add(boost::asio::ip::address_v4::from_string(m_pcIP),m_pcPort);
  42.       udp_sock.open(local_add.protocol());
  43.       udp_sock.bind(local_add);
  44.    }
  45.    //收数据
  46.    int receive_data(unsigned char buf[])
  47.    {
  48.       boost::mutex::scoped_lock lock(mutex);
  49.        //donot change 目的端口与发送端口现在是不一样的
  50.        boost::asio::ip::udp::endpoint send_endpoint(boost::asio::ip::address_v4::from_string(m_pcIP),m_pcPort); //这里的endpoint是PC机的IP和端口号
  51.        int ret = udp_sock.receive_from(boost::asio::buffer(buf,RECVSIZE),send_endpoint);//堵塞模式
  52.       return ret;
  53.    }
  54.    //发送数据
  55.    int send_data(unsigned char str[], int len)
  56.    {
  57.       boost::mutex::scoped_lock lock(mutex);
  58.       //donot change
  59.       boost::asio::ip::udp::endpoint send_endpoint(boost::asio::ip::address_v4::from_string(m_canetIP),m_canetPort); //canet的IP和端口号
  60.       int ret = udp_sock.send_to(boost::asio::buffer(str,len),send_endpoint);
  61.       return ret;
  62.    }
  63. public:
  64.    string m_canetIP;
  65.    int m_canetPort;
  66.    string m_pcIP;
  67.    int m_pcPort;
  68.    boost::asio::ip::udp::socket udp_sock;
  69.    mutable boost::mutex mutex;
  70. };
  71. #endif