C++ 组播接收发送实例 |21xrx.com

C++ 组播接收发送实例

2023-07-10 01:48:18 深夜i -- --

C++ 组播接收发送实例

C++是一种高级编程语言，具有强大的功能，其中包括实现组播接收和发送。组播是网络中广泛使用的一种通信方式，它允许将消息发送到多个接收者。在本文中，我们将探讨如何使用C++编写一个简单的组播发送和接收程序。

首先，让我们了解组播地址。组播地址具有特殊的IP地址范围，从224.0.0.0到239.255.255.255，这些地址都是保留地址。这些地址可以被多个接收者使用，因此，当向组播地址发送数据时，所有与组播地址相关联的接收者都将收到数据包。

在C++中，我们使用sockaddr_in结构体来表示IPv4地址，用于设置发送数据包的套接字信息。我们可以使用MulticastSocket类来创建套接字并设置组播地址和端口号。MulticastSocket还包括发送和接收数据包的方法。

要发送一个数据包，我们可以使用sendto()方法。此方法将调用sendto()函数，将数据包发送到组播地址。接收数据包可以使用recvfrom()方法。此方法将调用recvfrom()函数，用于接收来自组播地址的数据包。

下面是一个简单的C++程序，用于演示如何使用组播发送和接收：


#include <iostream>
#include <cstdlib>
#include <cstdio>
#include <cstring>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <netinet/in.h>
using namespace std;
#define BUF_SIZE 256
class MulticastSocket {
  private:
    int sock;
    struct sockaddr_in addr;
  public:
    MulticastSocket(char* group, int port) {
      if((sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0) {
        perror("socket() failed");
        exit(1);
      }
      memset(&addr, 0, sizeof(addr));
      addr.sin_family = AF_INET;
      addr.sin_addr.s_addr = inet_addr(group);
      addr.sin_port = htons(port);
      if(bind(sock, (struct sockaddr*)&addr, sizeof(addr)) < 0) {
        perror("bind() failed");
        exit(1);
      }
      struct ip_mreq mreq;
      mreq.imr_multiaddr.s_addr = inet_addr(group);
      mreq.imr_interface.s_addr = htonl(INADDR_ANY);
      if(setsockopt(sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, (void*)&mreq, sizeof(mreq)) < 0) {
        perror("setsockopt() failed");
        exit(1);
      }
    }
    ~MulticastSocket() {
      close(sock);
    }
    void send(char* msg) {
      int len = strlen(msg) + 1;
      if(sendto(sock, msg, len, 0, (struct sockaddr*)&addr, sizeof(addr)) < 0) {
        perror("sendto() failed");
      }
    }
    void recv() {
      char buf[BUF_SIZE];
      struct sockaddr_in from;
      socklen_t fromlen = sizeof(from);
      if(recvfrom(sock, buf, BUF_SIZE, 0, (struct sockaddr*)&from, &fromlen) < 0) {
        perror("recvfrom() failed");
        exit(1);
      }
      printf("Received message from %s:%d - %s\n", inet_ntoa(from.sin_addr), ntohs(from.sin_port), buf);
    }
};
int main() {
  char group[] = "239.0.0.1";
  int port = 8888;
  MulticastSocket ms(group, port);
  char msg[BUF_SIZE];
  while(1) {
    cout << "Enter message: ";
    fgets(msg, BUF_SIZE, stdin);
    msg[strlen(msg) - 1] = '\0';
    ms.send(msg);
    ms.recv();
  }
  return 0;
}

此代码创建了一个MulticastSocket类，用于处理发送和接收组播数据包。它将组播地址设置为239.0.0.1，端口号设置为8888。主函数无限循环，等待用户输入消息并将其发送到组播地址，然后接收来自组播地址的数据包并在终端上显示数据包的内容。

总之，使用C++编写组播发送和接收程序可以很容易地实现与多个接收者进行通信，并且这是一个非常重要的网络编程概念。希望本文能够帮助了解如何在C++中使用组播。

上一篇: idea打包java可执行jar包

下一篇: C++Map的自定义排序方法

评论区

()

相似文章