免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
最近访问板块 发新帖
查看: 1336 | 回复: 4
打印 上一主题 下一主题

UDP编程问题 [复制链接]

论坛徽章:
0
跳转到指定楼层
1 [收藏(0)] [报告]
发表于 2005-10-27 14:55 |只看该作者 |倒序浏览
现在有个在SGI工作站irix2.8系统下的程序,功能是:实现客户端向服务器发送信息,服务器显示后把收到的信息返回给客户端,然后客户再显示
代码如下:

/*           服务端程序  server.c           */
#include <stdlib.h>;
#include <stdio.h>;
#include <errno.h>;
#include <string.h>;
#include <unistd.h>;
#include <netdb.h>;
#include <sys/socket.h>;
#include <netinet/in.h>;
#include <sys/types.h>;
#include <arpa/inet.h>;
#define SERVER_PORT     8888
#define MAX_MSG_SIZE    1024

void udps_respon(int sockfd)
{
     struct sockaddr_in addr;
     int    n;
             socklen_t addrlen;
     char    msg[MAX_MSG_SIZE];
        
     while(1)
     {       /* 从网络上读,写到网络上面去   */
                             memset(msg, 0, sizeof(msg));
                             addrlen = sizeof(struct sockaddr);
                             n=recvfrom(sockfd,msg,MAX_MSG_SIZE,0,
                     (struct sockaddr*)&addr,&addrlen);
             /* 显示服务端已经收到了信息  */
             fprintf(stdout,"I have received %s",msg);
             sendto(sockfd,msg,n,0,(struct sockaddr*)&addr,addrlen);
     }
}

int main(void)
{
     int sockfd;
     struct sockaddr_in      addr;
        
     sockfd=socket(AF_INET,SOCK_DGRAM,0);
     if(sockfd<0)
     {
             fprintf(stderr,"Socket Error:%s\n",strerror(errno));
             exit(1);
     }
     bzero(&addr,sizeof(struct sockaddr_in));
     addr.sin_family=AF_INET;
     addr.sin_addr.s_addr=htonl(INADDR_ANY);
     addr.sin_port=htons(SERVER_PORT);
     if(bind(sockfd,(struct sockaddr *)&addr,sizeof(struct sockaddr_in))<0)
     {
             fprintf(stderr,"Bind Error:%s\n",strerror(errno));
             exit(1);
     }
     udps_respon(sockfd);
     close(sockfd);
}
-------------------------------------------------------------------------------/*          客户端程序             */
#include <stdlib.h>;
#include <stdio.h>;
#include <errno.h>;
#include <string.h>;
#include <unistd.h>;
#include <netdb.h>;
#include <sys/socket.h>;
#include <netinet/in.h>;
#include <sys/types.h>;
#include <arpa/inet.h>;
#define MAX_BUF_SIZE    1024

void udpc_requ(int sockfd,const struct sockaddr_in *addr,socklen_t len)
{
     char buffer[MAX_BUF_SIZE];
     int n;
     while(fgets(buffer,MAX_BUF_SIZE,stdin))         
     {        /*   从键盘读入,写到服务端   */
             n=sendto(sockfd,buffer,strlen(buffer),0,addr,len);
   if(n <= 0)
                             {
                                     fprintf(stderr, "Send Error %s\n", strerror(errno));  
             bzero(buffer,MAX_BUF_SIZE);

             /*   从网络上读,写到屏幕上    */
                             memset(buffer, 0, sizeof(buffer));
             n=recvfrom(sockfd,buffer,MAX_BUF_SIZE, 0, NULL, NULL);
             if(n <= 0)
                             {
                                     fprintf(stderr, "Recv Error %s\n", strerror(errno));
                                     return;
                             }
                             buffer[n]=0;
             fprintf(stderr, "get %s", buffer);
     }
}


int main(int argc,char **argv)
{
     int sockfd,port;
     struct sockaddr_in      addr;
        
     if(argc!=3)
     {
             fprintf(stderr,"Usage:%s server_ip server_port\n",argv[0]);
             exit(1);
     }
        
     if((port=atoi(argv[2]))<0)
     {
             fprintf(stderr,"Usage:%s server_ip server_port\n",argv[0]);
             exit(1);
     }
        
     sockfd=socket(AF_INET,SOCK_DGRAM,0);
     if(sockfd<0)
     {
             fprintf(stderr,"Socket  Error:%s\n",strerror(errno));
             exit(1);
     }      
     /*      填充服务端的资料      */
     bzero(&addr,sizeof(struct sockaddr_in));
     addr.sin_family=AF_INET;
     addr.sin_port=htons(port);
     if(inet_aton(argv[1],&addr.sin_addr)<0)
     {
             fprintf(stderr,"Ip error:%s\n",strerror(errno));
             exit(1);
     }
              if(connect(sockfd, (struct sockaddr *)&addr, sizeof(struct sockaddr_in)) == -1)
             {
                     fprintf(stderr, "connect error %s\n", strerror(errno));
                     exit(1);
             }
     udpc_requ(sockfd,&addr,sizeof(struct sockaddr_in));
     close(sockfd);
}
在sgi 工作站的irix 2.8系统上程序编译都通过了,但先运行
server.exe后再运行cilent.exe 127.0.0.1 8888 后输入字符串后,服务器端没有反应。这是为什么呢?
我用netstat -an查了一下UDP服务是起来的,端口号也是对的。
后发现在客户端运行到sendto 函数时,系统打印出错信息
Send error :transport endpoint is already connected
请问这是什么出错信息,改如何改正?
请哪为高手指点一下,非常感谢!!

论坛徽章:
0
2 [报告]
发表于 2005-10-27 14:58 |只看该作者

UDP编程问题

133  EISCONN         Transport endpoint is already connected
               A connect request was  made  on        an  already  connected
               transport  endpoint; or,        a sendto or sendmsg request on
               a connected transport endpoint specified        a  destination
               when already connected.

论坛徽章:
0
3 [报告]
发表于 2005-10-27 14:59 |只看该作者

UDP编程问题

怎么会发生这样的事情,我又如何在程序里改正它呢?

论坛徽章:
0
4 [报告]
发表于 2005-10-27 15:01 |只看该作者

UDP编程问题

A connect request was  made  on an  already  connected transport  endpoint
说的已经很清楚了。翻译成中文看看!

论坛徽章:
0
5 [报告]
发表于 2005-10-27 15:11 |只看该作者

UDP编程问题

看清楚了,可是不太理解,那个端口没有被其他的程序占用呀。别卖关子了,我这里都急死了,
您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

  

北京盛拓优讯信息技术有限公司. 版权所有 京ICP备16024965号-6 北京市公安局海淀分局网监中心备案编号:11010802020122 niuxiaotong@pcpop.com 17352615567
未成年举报专区
中国互联网协会会员  联系我们:huangweiwei@itpub.net
感谢所有关心和支持过ChinaUnix的朋友们 转载本站内容请注明原作者名及出处

清除 Cookies - ChinaUnix - Archiver - WAP - TOP