基本OpenPGM设置

#include <pgm.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#define GROUP_ADDRESS "224.1.1.1"
#define PORT 4000

void sender() {
    pgm_socket_t *socket = pgm_create_socket(PGM_UDP);
    pgm_bind(socket, PORT);

    char *message = "Hello, PGM!";
    pgm_send(socket, message, strlen(message), GROUP_ADDRESS, 0);

    pgm_close(socket);
}

void receiver() {
    pgm_socket_t *socket = pgm_create_socket(PGM_UDP);
    pgm_bind(socket, PORT);

    char buffer[1024];
    ssize_t received_bytes;
    while (1) {
        received_bytes = pgm_recv(socket, buffer, sizeof(buffer), NULL);
        if (received_bytes > 0) {
            buffer[received_bytes] = '\0';
            printf("Received: %s\n", buffer);
        }
    }

    pgm_close(socket);
}

int main(int argc, char *argv[]) {
    if (argc == 2 && strcmp(argv[1], "sender") == 0) {
        sender();
    } else if (argc == 2 && strcmp(argv[1], "receiver") == 0) {
        receiver();
    } else {
        printf("Usage: %s [sender|receiver]\n", argv[0]);
    }
    return 0;
}