[udp] multicast send

//// sender

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <unistd.h>

#include <netinet/in.h>

#include <arpa/inet.h>

#define MULTICAST_ADDR "239.0.0.1"

#define PORT 8888

#define FILENAME "test.txt"

int main(int argc, char **argv)

{

int sock;

struct sockaddr_in addr;

char buf[1024];

int read_len, send_len, total_len;

FILE *fp;

struct ip_mreq mreq;

int enable = 1;

// 파일 열기

fp = fopen(FILENAME, "r");

if (fp == NULL)

{

perror("Failed to open file");

exit(EXIT_FAILURE);

}

// 멀티캐스트 소켓 생성

sock = socket(AF_INET, SOCK_DGRAM, 0);

if (sock < 0)

{

perror("Failed to create socket");

exit(EXIT_FAILURE);

}

// 멀티캐스트 TTL 설정

setsockopt(sock, IPPROTO_IP, IP_MULTICAST_TTL, &enable, sizeof(enable));

// 멀티캐스트 그룹에 참여

mreq.imr_multiaddr.s_addr = inet_addr(MULTICAST_ADDR);

mreq.imr_interface.s_addr = htonl(INADDR_ANY);

setsockopt(sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq));

// 소켓 주소 설정

memset(&addr, 0, sizeof(addr));

addr.sin_family = AF_INET;

addr.sin_addr.s_addr = inet_addr(MULTICAST_ADDR);

addr.sin_port = htons(PORT);

// 파일 읽어서 멀티캐스트로 전송

while ((read_len = fread(buf, 1, sizeof(buf), fp)) > 0)

{

total_len = 0;

while (total_len < read_len)

{

send_len = sendto(sock, buf + total_len, read_len - total_len, 0,

(struct sockaddr *)&addr, sizeof(addr));

if (send_len < 0)

{

perror("Failed to send data");

exit(EXIT_FAILURE);

}

total_len += send_len;

}

}

// 파일과 소켓 닫기

fclose(fp);

close(sock);

return 0;

}