Jump to content

  • Log In with Google      Sign In   
  • Create Account


UDP Client Server Echo Example


Old topic!
Guest, the last post of this topic is over 60 days old and at this point you may not reply in this topic. If you wish to continue this conversation start a new topic.

  • You cannot reply to this topic
7 replies to this topic

#1 John Schultz   Members   -  Reputation: 807

Like
0Likes
Like

Posted 30 March 2005 - 02:14 PM

Here's an example UDP echo server I created from a simple UDP example (originally to help another thread question, now solved). Additionally, it shows how to use select() to poll the socket (with an optional time out).

Compiled and tested on and between Win32/Cygwin and Linux (would need to be modified for Win32/Winsock).

Compile:
gcc -Wall -o client udpClient.c
gcc -Wall -o server udpServer.c

Run:
./server&
./client 127.0.0.1 this is a test.

(or run server in another console, separate machines, etc.).


Client:

/* fpont 12/99 */
/* pont.net    */
/* udpClient.c */

/* Converted to echo client/server with select() (timeout option) */
/* 3/30/05 John Schultz */

#include <stdlib.h> /* for exit() */
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h> /* memset() */
#include <sys/time.h> /* select() */ 

#define REMOTE_SERVER_PORT 1500
#define MAX_MSG 100

/* BEGIN jcs 3/30/05 */

#define SOCKET_ERROR -1

int isReadable(int sd,int * error,int timeOut) { // milliseconds
  fd_set socketReadSet;
  FD_ZERO(&socketReadSet);
  FD_SET(sd,&socketReadSet);
  struct timeval tv;
  if (timeOut) {
    tv.tv_sec  = timeOut / 1000;
    tv.tv_usec = (timeOut % 1000) * 1000;
  } else {
    tv.tv_sec  = 0;
    tv.tv_usec = 0;
  } // if
  if (select(sd+1,&socketReadSet,0,0,&tv) == SOCKET_ERROR) {
    *error = 1;
    return 0;
  } // if
  *error = 0;
  return FD_ISSET(sd,&socketReadSet) != 0;
} /* isReadable */

/* END jcs 3/30/05 */

int main(int argc, char *argv[]) {
  
  int sd, rc, i, n, echoLen, flags, error, timeOut;
  struct sockaddr_in cliAddr, remoteServAddr, echoServAddr;
  struct hostent *h;
  char msg[MAX_MSG];


  /* check command line args */
  if(argc<3) {
    printf("usage : %s <server> <data1> ... <dataN> \n", argv[0]);
    exit(1);
  }

  /* get server IP address (no check if input is IP address or DNS name */
  h = gethostbyname(argv[1]);
  if(h==NULL) {
    printf("%s: unknown host '%s' \n", argv[0], argv[1]);
    exit(1);
  }

  printf("%s: sending data to '%s' (IP : %s) \n", argv[0], h->h_name,
	 inet_ntoa(*(struct in_addr *)h->h_addr_list[0]));

  remoteServAddr.sin_family = h->h_addrtype;
  memcpy((char *) &remoteServAddr.sin_addr.s_addr, 
	 h->h_addr_list[0], h->h_length);
  remoteServAddr.sin_port = htons(REMOTE_SERVER_PORT);

  /* socket creation */
  sd = socket(AF_INET,SOCK_DGRAM,0);
  if(sd<0) {
    printf("%s: cannot open socket \n",argv[0]);
    exit(1);
  }
  
  /* bind any port */
  cliAddr.sin_family = AF_INET;
  cliAddr.sin_addr.s_addr = htonl(INADDR_ANY);
  cliAddr.sin_port = htons(0);
  
  rc = bind(sd, (struct sockaddr *) &cliAddr, sizeof(cliAddr));
  if(rc<0) {
    printf("%s: cannot bind port\n", argv[0]);
    exit(1);
  }

/* BEGIN jcs 3/30/05 */

  flags = 0;

  timeOut = 100; // ms

/* END jcs 3/30/05 */

  /* send data */
  for(i=2;i<argc;i++) {
    rc = sendto(sd, argv[i], strlen(argv[i])+1, flags, 
		(struct sockaddr *) &remoteServAddr, 
		sizeof(remoteServAddr));

    if(rc<0) {
      printf("%s: cannot send data %d \n",argv[0],i-1);
      close(sd);
      exit(1);
    }

/* BEGIN jcs 3/30/05 */

    /* init buffer */
    memset(msg,0x0,MAX_MSG);

    while (!isReadable(sd,&error,timeOut)) printf(".");
    printf("\n");

    /* receive echoed message */
    echoLen = sizeof(echoServAddr);
    n = recvfrom(sd, msg, MAX_MSG, flags,
      (struct sockaddr *) &echoServAddr, &echoLen);

    if(n<0) {
      printf("%s: cannot receive data \n",argv[0]);
      continue;
    }

    /* print received message */
    printf("%s: echo from %s:UDP%u : %s \n", 
      argv[0],inet_ntoa(echoServAddr.sin_addr),
      ntohs(echoServAddr.sin_port),msg);

/* END jcs 3/30/05 */

  }
  
  return 1;

}






Server:

/* fpont 12/99 */
/* pont.net    */
/* udpServer.c */

/* Converted to echo client/server with select() (timeout option). See udpClient.c */
/* 3/30/05 John Schultz */

#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <stdio.h>
#include <unistd.h> /* close() */
#include <string.h> /* memset() */

#define LOCAL_SERVER_PORT 1500
#define MAX_MSG 100

int main(int argc, char *argv[]) {
  
  int sd, rc, n, cliLen, flags;
  struct sockaddr_in cliAddr, servAddr;
  char msg[MAX_MSG];

  /* socket creation */
  sd=socket(AF_INET, SOCK_DGRAM, 0);
  if(sd<0) {
    printf("%s: cannot open socket \n",argv[0]);
    exit(1);
  }

  /* bind local server port */
  servAddr.sin_family = AF_INET;
  servAddr.sin_addr.s_addr = htonl(INADDR_ANY);
  servAddr.sin_port = htons(LOCAL_SERVER_PORT);
  rc = bind (sd, (struct sockaddr *) &servAddr,sizeof(servAddr));
  if(rc<0) {
    printf("%s: cannot bind port number %d \n", 
	   argv[0], LOCAL_SERVER_PORT);
    exit(1);
  }

  printf("%s: waiting for data on port UDP %u\n", 
	   argv[0],LOCAL_SERVER_PORT);

/* BEGIN jcs 3/30/05 */

  flags = 0;

/* END jcs 3/30/05 */

  /* server infinite loop */
  while(1) {
    
    /* init buffer */
    memset(msg,0x0,MAX_MSG);

    /* receive message */
    cliLen = sizeof(cliAddr);
    n = recvfrom(sd, msg, MAX_MSG, flags,
		 (struct sockaddr *) &cliAddr, &cliLen);

    if(n<0) {
      printf("%s: cannot receive data \n",argv[0]);
      continue;
    }
      
    /* print received message */
    printf("%s: from %s:UDP%u : %s \n", 
	   argv[0],inet_ntoa(cliAddr.sin_addr),
	   ntohs(cliAddr.sin_port),msg);

/* BEGIN jcs 3/30/05 */

    sleep(1);
    sendto(sd,msg,n,flags,(struct sockaddr *)&cliAddr,cliLen);

/* END jcs 3/30/05 */
    
  }/* end of server infinite loop */

return 0;

}





[Edited by - John Schultz on March 31, 2005 3:13:44 PM]

Sponsor:

#2 hplus0603   Moderators   -  Reputation: 4979

Like
0Likes
Like

Posted 31 March 2005 - 05:03 AM

Thanks for sharing!

However, the headers of that code appear to credit "Frederic Pont" from www.pont.net, not John Schultz. Looking at that web site, it's un-clear to me what part of this that _you_ created.

Remember that mis-representation of copyright is a federal crime, and is not something you should be doing, even in a friendly forum such as this.

#3 Pipo DeClown   Members   -  Reputation: 804

Like
0Likes
Like

Posted 31 March 2005 - 05:12 AM

Quote:
Original post by hplus0603
Thanks for sharing!

However, the headers of that code appear to credit "Frederic Pont" from www.pont.net, not John Schultz. Looking at that web site, it's un-clear to me what part of this that _you_ created.

Remember that mis-representation of copyright is a federal crime, and is not something you should be doing, even in a friendly forum such as this.


Check his own /*comments*/ underneath those original comments.
I'm not back. I'm just visiting.

#4 John Schultz   Members   -  Reputation: 807

Like
0Likes
Like

Posted 31 March 2005 - 08:20 AM

Quote:
Original post by hplus0603
Thanks for sharing!

However, the headers of that code appear to credit "Frederic Pont" from www.pont.net, not John Schultz. Looking at that web site, it's un-clear to me what part of this that _you_ created.

Remember that mis-representation of copyright is a federal crime, and is not something you should be doing, even in a friendly forum such as this.


Perhaps you are thinking about another post? There are no headers here (two source files). It appeared the changes I made would be clear based on the comments I added to the code (conversion of simple UDP client/server to an echo client server); the code is very short/trivial.

I have edited the original post and added additional comments around the code I changed/added.

What lead you to believe there was a violation of US Copyright law?


#5 hplus0603   Moderators   -  Reputation: 4979

Like
0Likes
Like

Posted 31 March 2005 - 09:58 AM

Quote:
Here's an example UDP echo server I created


When I read this, it sounded to me like you claimed authorship. I like the edits, and, again, thanks for sharing!

#6 John Schultz   Members   -  Reputation: 807

Like
0Likes
Like

Posted 31 March 2005 - 10:28 AM

Quote:
Original post by hplus0603
Quote:
Here's an example UDP echo server I created


When I read this, it sounded to me like you claimed authorship. I like the edits, and, again, thanks for sharing!


No problem! Hopefully this code will be useful for those just starting out or needing to test basic UDP functionality.

I am sensitive to copyright law as my own code (licensed to another companies) has been misrepresented in the past (my name removed from the copyright line and another's substituted). An example of a Virtual Reality headset SDK I wrote in 1994 here. It appears my name has been completely removed, except for my initials in the serial bi-modal assembly file. The company went out of business years ago.

#7 Hexxagonal   Members   -  Reputation: 138

Like
0Likes
Like

Posted 13 April 2005 - 04:43 AM

[Note: moved this to it's own thread for ease of reading]

I just tried a modified version of this code for a class project I'm doing where I keep sending out packets, and then instead of a while, I used an if on the isReadable (my version) and then if isReadable == 1 then I would recvfrom the data. I did this and I my data was somewhat corrupted as opposed to simply doing a sendto and then blocking with a recvfrom. Any ideas (I'm checking the actual bytes and they are different btw).

Here's my function, thanks in advance if you guys have any ideas. I'm stumped.

// isReadable
// Checks to see if the Socket has something to be read
int isReadable( int sockfd, int usec ) {
fd_set socketReadSet;
FD_ZERO(&socketReadSet);
FD_SET(sockfd, &socketReadSet);

// Setup timeout
struct timeval tv;
if( usec ) {
tv.tv_sec = usec / 1000000;
tv.tv_usec = (usec % 1000000);
} else {
tv.tv_sec = 0;
tv.tv_usec = 0;
} // end if



// Select on our Socket Description
if( select(sockfd+1,&socketReadSet,0,0,&tv) == -1 ) {
perror("select");
exit(1);
}

return FD_ISSET(sockfd,&socketReadSet) != 0;

} // end isReadable


[Edited by - Hexxagonal on April 13, 2005 12:43:36 PM]

#8 John Schultz   Members   -  Reputation: 807

Like
0Likes
Like

Posted 13 April 2005 - 08:05 AM

Hi,

select() will not have any effect on data received with recvfrom(). If your isReadable() was somehow broken (it looks OK), worst case is you'd see old data as new data was not present (if the socket was set to non-blocking and you were not checking for errors returned by recvfrom()), or you would block waiting for data to actually arrive (blocking socket).

Make sure you are error checking recvfrom(), and also look at how your read buffer is handled (on stack, class member, global, etc.).




Old topic!
Guest, the last post of this topic is over 60 days old and at this point you may not reply in this topic. If you wish to continue this conversation start a new topic.



PARTNERS