📄 94.htm

📁 unix高级编程原吗
💻 HTM
字号:
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=gb2312">
<title>CTerm非常精华下载</title>
</head>
<body bgcolor="#FFFFFF">
<table border="0" width="100%" cellspacing="0" cellpadding="0" height="577">
<tr><td width="32%" rowspan="3" height="123"><img src="DDl_back.jpg" width="300" height="129" alt="DDl_back.jpg"></td><td width="30%" background="DDl_back2.jpg" height="35"><p align="center"><a href="http://apue.dhs.org"><font face="黑体"><big><big>123</big></big></font></a></td></tr>
<tr>
<td width="68%" background="DDl_back2.jpg" height="44"><big><big><font face="黑体"><p align="center">               ● UNIX网络编程                       (BM: clown)                </font></big></big></td></tr>
<tr>
<td width="68%" height="44" bgcolor="#000000"><font face="黑体"><big><big><p   align="center"></big></big><a href="http://cterm.163.net"><img src="banner.gif" width="400" height="60" alt="banner.gif"border="0"></a></font></td>
</tr>
<tr><td width="100%" colspan="2" height="100" align="center" valign="top"><br><p align="center">[<a href="index.htm">回到开始</a>][<a href="54.htm">上一层</a>][<a href="95.htm">下一篇</a>]
<hr><p align="left"><small>发信人: clown (梧桐叶), 信区: UNP <br>

标  题: 多播测试程序 <br>

发信站: UNIX编程 (2001年10月09日16:31:41 星期二), 站内信件 <br>

  <br>

//server <br>

//回显程序 <br>

  <br>

#include <stdio.h> <br>

#include <sys/types.h> <br>

#include <sys/socket.h> <br>

#include <netinet/in.h> <br>

#include <string.h> <br>

#include <sys/time.h> <br>

#include <arpa/inet.h> <br>

#include <errno.h> <br>

  <br>

#define MIP "224.0.3.1" <br>

#define INTERFACE "192.168.1.69" <br>

#define PORT 8001 <br>

  <br>

int main() <br>

{ <br>

    int fd, maxfd1; <br>



    struct sockaddr_in saddr, caddr; <br>

    char receive[32], addr[16]; //client's ip address <br>

    int n;  //the characters received from socket <br>

    int len;  //the length of the struct sockaddr_in <br>

    const int on = 1; <br>

    struct ip_mreq mreq; <br>

  <br>

    errno = 0; <br>

    if((fd=socket(AF_INET, SOCK_DGRAM, 0)) == -1) { <br>

        printf("socket error\n"); <br>

        exit(1); <br>

    } <br>

//加入到多播组 <br>

    if((n=inet_pton(AF_INET, MIP, (void *)&mreq.imr_multiaddr)) == -1) { <br>

        perror("inet_pton error"); <br>

        exit(1); <br>

    } else if(n == 0) { <br>

        printf("%s is not a legal mutiaddr\n", MIP); <br>

        exit(1); <br>

    } <br>

//在哪个接口上加入多播组？ <br>

    if((n=inet_pton(AF_INET, INTERFACE, (void *)&mreq.imr_interface)) == -1) { <br>



        perror("inet_pton error"); <br>

        exit(1); <br>

    } else if(n == 0) { <br>

        printf("%s is not a legal interface addr\n", INTERFACE); <br>

        exit(1); <br>

  <br>

    } <br>

    //set socket option <br>

    if(setsockopt(fd, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq)) <br>

            == -1) { <br>

        printf("set socket option error\n"); <br>

        exit(1); <br>

    } <br>

    if(setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)) < 0) { <br>

        printf("set socket option error\n"); <br>

        exit(1); <br>

    } <br>

  <br>

  <br>

    memset(&saddr, 0, sizeof(saddr)); <br>

    saddr.sin_family = AF_INET; <br>

    inet_pton(AF_INET, MIP, (void *)&saddr.sin_addr.s_addr); <br>



    saddr.sin_port = htons(PORT); <br>

    if(bind(fd, (struct sockaddr *)&saddr, sizeof(saddr)) == -1) { <br>

        perror("bind error"); <br>

        exit(1); <br>

    } <br>

  <br>

    for( ; ;) { <br>

        len = sizeof(caddr); <br>

        if((n = recvfrom(fd, receive, sizeof(receive)-1, 0, (struct sockaddr *)& <br>

ca <br>

ddr, &len)) == -1) { <br>

            printf("recvfrom error\n"); <br>

            break; <br>

        } <br>

        receive[n] = '\0'; <br>

        printf("From %s, Port %d: %s", inet_ntop(AF_INET, &caddr.sin_addr, addr, <br>

 s <br>

izeof(addr)), ntohs(caddr.sin_port), receive); <br>

        if(sendto(fd, receive, strlen(receive), 0, (struct sockaddr *)&caddr, le <br>

n) <br>

 == -1) { <br>

            printf("sendto error\n"); <br>



            exit(1); <br>

        } <br>

        if(getsockname(fd, (struct sockaddr *)&caddr, &len) == -1) { <br>

            perror("getsockname error"); <br>

            exit(1); <br>

        } else <br>

            printf("Local %s, Port %d\n", inet_ntop(AF_INET, &caddr.sin_addr, ad <br>

dr, s <br>

izeof(addr)), ntohs(caddr.sin_port)); <br>

    } //end of for <br>

    return 0; <br>

} <br>

  <br>

  <br>

//clinet <br>

  <br>

#include <stdio.h> <br>

#include <unistd.h> <br>

#include <netinet/in.h> <br>

#include <arpa/inet.h> <br>

#include <sys/types.h> <br>

#include <sys/socket.h> <br>



#include <string.h> <br>

#include <sys/time.h> <br>

#include <signal.h> <br>

#include <errno.h> <br>

#include <setjmp.h> <br>

  <br>

#define SERV_PORT 8001 <br>

#define LOCAL_PORT 8001 <br>

void str_cli(FILE *fp, int sockfd, const struct sockaddr *paddr, int len); <br>

void sig(int); <br>

extern int errno; <br>

  <br>

static sigjmp_buf jmpbuf; <br>

int main(int argc, char **argv) <br>

{ <br>

    int i, sockfd; <br>

    const int on = 1; <br>

    struct sockaddr_in servaddr, cliaddr; <br>

    if(argc != 2) { <br>

        printf("usage: %s <IPaddress>\n", argv[0]); <br>

        exit(1); <br>

    } <br>

    } <br>

  <br>

    errno = 0; <br>

    if((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) { <br>

        printf("create socket error\n"); <br>

        exit(1); <br>

    } <br>

    //set socket option <br>

    if(setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)) == -1) { <br>

        printf("set socket option error\n"); <br>

        exit(1); <br>

    } <br>

  <br>

    memset(&cliaddr, 0, sizeof(cliaddr)); <br>

    cliaddr.sin_family = AF_INET; <br>

    cliaddr.sin_port = htons(LOCAL_PORT); <br>

    //bind local port <br>

//绑定本地端口8001，tcp和udp客户端都可以绑定发送数据报的本地端口 <br>

//这一步不是必需的 <br>

    if(bind(sockfd, (struct sockaddr *)&cliaddr, sizeof(cliaddr)) < 0) { <br>

        perror("bind error"); <br>

        exit(1); <br>

    } <br>

    } <br>

  <br>

    memset(&servaddr, 0, sizeof(servaddr)); <br>

    servaddr.sin_family = AF_INET; <br>

    servaddr.sin_port = htons(SERV_PORT); <br>

    if(inet_pton(AF_INET, argv[1], &servaddr.sin_addr) <= 0) { <br>

        printf("inet_pton error\n"); <br>

        exit(1); <br>

    } <br>

  <br>

    str_cli(stdin, sockfd, (struct sockaddr*)&servaddr, sizeof(servaddr)); <br>

    //close(sockfd); <br>

    return 0; <br>

} <br>

  <br>

void str_cli(FILE *fp, int sockfd, const struct sockaddr *paddr, int len) <br>

{ <br>

    char sendline[32], recvline[32], straddr[16];  //server's ip address <br>

    int n, saddrlen, caddrlen; <br>

    struct sockaddr_in saddr, caddr; <br>

  <br>

    signal(SIGALRM, sig); <br>

    while(fgets(sendline, 32, fp) != NULL) { <br>



        if(sendto(sockfd, sendline, strlen(sendline), 0, paddr, len) < 0) { <br>

            perror("send"); <br>

            return; <br>

        } <br>

//3秒钟以后不再接收多播服务器的回应 <br>

        alarm(3); <br>

        for( ; ; ) { <br>

            if(sigsetjmp(jmpbuf, 1) > 0) { <br>

                printf("time reached\n"); <br>

                break; <br>

            } <br>

            memset(&saddr, 0, sizeof(saddr)); <br>

            saddrlen = sizeof(saddr); <br>

            if((n = recvfrom(sockfd, recvline, 31, 0, (struct sockaddr *)&saddr, <br>

 &sad <br>

drlen)) < 0) { <br>

                perror("recv error"); <br>

                return; <br>

            } <br>

            recvline[n] = '\0'; <br>

            printf("From %s, Port %d: %s", inet_ntop(AF_INET, &saddr.sin_addr, s <br>

tradd <br>

tradd <br>

r, sizeof(straddr)), ntohs(saddr.sin_port), recvline); <br>

  <br>

            memset(&caddr, 0, sizeof(caddr)); <br>

            caddrlen = sizeof(caddr); <br>

            if(getsockname(sockfd, (struct sockaddr *)&caddr, &caddrlen) == -1) <br>

{ <br>

                perror("getsockname error"); <br>

                exit(1); <br>

            } else <br>

                printf("Local %s, Port %d\n", inet_ntop(AF_INET, &caddr.sin_addr <br>

, stradd <br>

r, sizeof(straddr)), ntohs(caddr.sin_port)); <br>

        } //end of for <br>

  <br>

    }  //end of while <br>

} <br>

  <br>

void sig(int signo) <br>

{ <br>

    siglongjmp(jmpbuf, 1); <br>

} <br>

  <br>

  <br>

//result <br>

//在两个终端上面运行了服务器程序，因此客户收到了两个应答。 <br>

  <br>

//客户端 <br>

$./mcli 224.0.3.1 <br>

From 192.168.1.69, Port 8001: hi <br>

Local 0.0.0.0, Port 8001 <br>

From 192.168.1.69, Port 8001: hi <br>

Local 0.0.0.0, Port 8001 <br>

time reached <br>

From 192.168.1.69, Port 8001: hello <br>

Local 0.0.0.0, Port 8001 <br>

From 192.168.1.69, Port 8001: hello <br>

Local 0.0.0.0, Port 8001 <br>

time reached <br>

  <br>

//服务器 <br>

$tty <br>

/dev/tty1 <br>

$./mser <br>

From 192.168.1.152, Port 8001: hi <br>

Local 224.0.3.1, Port 8001 <br>



From 192.168.1.152, Port 8001: hello <br>

Local 224.0.3.1, Port 8001 <br>

  <br>

$tty <br>

/dev/tty2 <br>

$./mser <br>

From 192.168.1.152, Port 8001: hi <br>

Local 224.0.3.1, Port 8001 <br>

From 192.168.1.152, Port 8001: hello <br>

Local 224.0.3.1, Port 8001 <br>

  <br>

  <br>

-- <br>

易朽的是生命，似那转瞬即谢的花朵；然而永存的，是对未来的渴望， <br>

是那生生世世传递下来的，不朽的，生的激情。每一朵勇敢开放的花， <br>

都是一个死亡唇边的微笑。 <br>

※ 来源:·UNIX编程 www.tiaozhan.com/unixbbs/·[FROM: 211.69.205.23] <br>

</small><hr>
<p align="center">[<a href="index.htm">回到开始</a>][<a href="54.htm">上一层</a>][<a href="95.htm">下一篇</a>]
<p align="center"><a href="http://cterm.163.net">欢迎访问Cterm主页</a></p>
</table>
</body>
</html>
💿 文件大小 1476 K
👤 上传用户 eeworm
📂 所属分类 Linux/Unix编程
🏷️ 相关标签

#unix #高级编程
⌨️ 快捷键说明

复制代码 Ctrl + C
搜索代码 Ctrl + F
全屏模式 F11
切换主题 Ctrl + Shift + D
显示快捷键 ?
增大字号 Ctrl + =
减小字号 Ctrl + -