멀티캐스트 관련 질문입니다.

안녕하세요...
멀티캐스트를 공부하고 있습니다.
제가 간단하게 테스트하고 있는 것은 sender, receive 입니다.
sender에서 멀티캐스트 그룹으로 데이터 송신하고, receive에서는 멀티캐스트 그룹에 가입하여 데이터를 수신합니다. 테스트를 해보니 잘 됩니다.
그러나 sender에서 receiver로 멀티캐스트로 패킷을 단방향으로만 전송을 하고 있는데, 저는 양방향을 원하고 있습니다.
즉, sender에서 receiver로는 멀티캐스트 그룹으로 데이터 전송, receiver에서는 sender가 보낸 데이터를 수신하고, 또한 receiver에서 sender로 일반 udp 패킷 전송을 원합니다. 테스트를 해봤는데, 잘 안되더라구요,,,
안되는 부분 sender.c 의 recvfrom() 에서 데이터 수신이 안됩니다.

원래 안되는 것인지 아니면, 다른 어떤 방법이 있는것인지 궁금하네요..
참고로 receiver에서 sender로 멀티캐스트 전송은 된다는 것을 알고있습니다.
아래는 이 부분에 관한 소스입니다.
<sender.c>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <sys/socket.h>

#define TTL 64
#define BUFSIZE 30
void error_handling(char *message);

int main(int argc, char **argv)
{
int send_sock;
struct sockaddr_in multi_addr;
int multi_TTL = TTL;
int state, loop;
FILE *fp;
char buf[BUFSIZE];

if(argc != 3) {
printf("Usage%s<IP> <port>\n", argv[0]);
}

send_sock = socket(PF_INET, SOCK_DGRAM, 0);
if(send_sock == -1)
error_handling("socket() error");

memset(&multi_addr, 0, sizeof(multi_addr));
multi_addr.sin_family = AF_INET;
multi_addr.sin_addr.s_addr = inet_addr(argv[1]);
multi_addr.sin_port = htons(atoi(argv[2]));

state = setsockopt(send_sock, IPPROTO_IP, IP_MULTICAST_TTL, (void *) &multi_TTL, sizeof(multi_TTL));

if(state)
error_handling("setsockopt() error");

loop = 0;
state = setsockopt(send_sock, IPPROTO_IP, IP_MULTICAST_LOOP,
(void *)&loop, sizeof(loop));

if(state)
error_handling("setsockopt() error");

if((fp = fopen("News.txt", "r"))==NULL)
error_handling("fopen() error");

while(!feof(fp)) {
fgets(buf, BUFSIZE, fp);
sendto(send_sock, buf, strlen(buf), 0, (struct sockaddr*)&multi_addr,
sizeof(multi_addr));
sleep(1);
int str_len;
if((str_len = recvfrom(send_sock, buf, str_len, 0, NULL, 0)) >0)
fputs(buf, stdout);
}

close(send_sock);

return 0;
}

void error_handling(char *message)
{
fputs(message, stderr);
fputc('\n', stderr);

exit(1);
}

<receiver.c>
#include <arpa/inet.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <errno.h>

#define BUFSIZE 30
void error_handling(char *message);

int main(int argc, char **argv)
{
int recv_sock;
struct sockaddr_in addr, send_addr;
int state, str_len;
char buf[BUFSIZE];
//char message[BUFSIZE];
char *message;
struct ip_mreq join_addr;
message = "Thank you";

if(argc != 3) {
printf("Usage%s<IP> <port>\n", argv[0]);
}

recv_sock=socket(PF_INET, SOCK_DGRAM, 0);
if(recv_sock == -1)
error_handling("socket() error");

memset(&addr, 0, sizeof(addr));
addr.sin_family = AF_INET;
addr.sin_addr.s_addr = htonl(INADDR_ANY);
addr.sin_port = htons(atoi(argv[2]));

if(bind(recv_sock, (struct sockaddr*) &addr, sizeof(addr))==-1)
error_handling("bind() error");

join_addr.imr_multiaddr.s_addr = inet_addr(argv[1]);
join_addr.imr_interface.s_addr = htonl(INADDR_ANY);

state = setsockopt(recv_sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, (void*) &join_addr, sizeof(join_addr));
// error

if(state) {
printf("state %d\n", state);
perror("setsockopt() error\n");
error_handling("setsockopt() error");
}

while(1) {
int size_send_addr = sizeof(send_addr);
str_len = recvfrom(recv_sock, buf, BUFSIZE-1, 0, (struct sockaddr*)&send_addr, &size_send_addr);
if(str_len < 0) break;
buf[str_len] = 0;
fputs(buf, stdout);
sendto(recv_sock, message, strlen(message), 0, (struct sockaddr*)&send_addr, sizeof(send_addr));
}
close(recv_sock);
return 0;
}

void error_handling(char *message)
{
fputs(message, stderr);
fputc('\n', stderr);

exit(1);
}