欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Linux C之Socket通信(UDP协议)

程序员文章站 2022-06-30 09:14:48
...

一 . UDP实现基本流程(C/S架构)

server端
  • socket()
  • bind()
  • recfrom() sendto()
  • close()
client端
  • socket()
  • recfrom() sendto()
  • close()

二 . server端分步编程:

1.函数头文件
#include <stdio.h>
#include <stdlib.h>
#include <error.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
2.宏定义和变量声明:
#define PORT 9999 //指定监听端口
int socket_fd   //套接字
struct sockaddr_in server,client;  //server和client的结构体
char sendbuf[] = "server ACK";  //server回复给client的信息
char recbuf[1024];  //接受数据的数组
char *addr = "127.0.0.1";  //指定监听地址
int len; //结构体长度
3.socket初始化:
void socket_init()
{
  server.sin_family = AF_INET;
  server.sin_port = htons(PORT);
  inet_pton(AF_INET,addr,&server.sin_addr);
  socket_fd = socket(AF_INET,SOCK_DGRAM,0);
  if(socket_fd<0)  //返回值为零,则创建套接字失败
  {
     perror("socket error:");
     exit(1);
  }
  if(bind(socket_fd,(struct sockaddr*)&server,sizeof(server))<0)
  {
    perror("bind error:");
    exit(1);
  }
} 
4 . server main函数:
int main()
{
   socket_init();
   printf("This is udp server\n");
   while(1)
   {
     len=sizeof(client);
     rec=recvfrom(socket_fd,recbuf,sizeof(recbuf),0,(struct sockaddr*)&client,&len);
     if(rec<0)
     {
        perror("recvform error:");
        exit(1);
     }
     printf("server_recform:%s\t",recbuf);
     sen=sendto(socket_fd,sendbuf,sizeof(sendbuf),0,(struct sockaddr*)&client,len);
     if(sen<0)
     {
       perror("sendto error:");
       exit(1);
     }
     inet_ntop(AF_INET,&client.sin_addr.s_addr,str,16);
     printf("client_addr:%s\t",str);
     printf("client_port=%d\n",ntohs(client.sin_port));
   }
   close(socket_fd);
  return 0;
}

三 . client端分步编程:

1.函数头文件:
#include <stdio.h>
#include <stdlib.h>
#include <error.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
2.宏定义和变量声明:
#define PORT 9999 
int socket_fd;
struct sockaddr_in server;
char sendbuf[1024],recbuf[1024];
int len,sent,rec;
char *addr = "127.0.0.1";
3.socket初始化:
void socket_init()
{
   server.sin_family = AF_INET;
   server.sin_port = htons(PORT);
   inet_pton(AF_INET,addr,&server.sin_addr.s_addr);
   socket_fd = socket(AF_INET,SOCK_DGRAM,0);
   if(socket_fd<0)
   {
     perror("socket:");
     exit(1);
   }
   len = sizeof(struct sockaddr);
}
4 . client main函数:
int main()
{
   socket_init();
   printf("This is udp client:\n");
   while(1)
   {
      printf("please input string:");
      scanf("%s",sendbuf);
      printf("OK!\n");
      sent = sendto(socket_fd,sendbuf,sizeof(sendbuf),0,(struct sockaddr*)&server,len);
      if(sent<0)
        printf("sent error\n");
      rec = recvfrom(socket_fd,recbuf,sizeof(recbuf),0,NULL,NULL);
      if(rec<0)
        printf("rec error\n");
      printf("client_recfrom:%s\n",recbuf);
   }
   close(socket_fd);
   return 0;
}
程序最终运行图:

Linux C之Socket通信(UDP协议)