雷火电竞-中国电竞赛事及体育赛事平台

歡迎來到入門教程網(wǎng)!

C語言

當(dāng)前位置:主頁 > 軟件編程 > C語言 >

Linux中使用C語言實(shí)現(xiàn)基于UDP協(xié)議的Socket通信示例

來源:本站原創(chuàng)|時間:2020-01-10|欄目:C語言|點(diǎn)擊:

linux下udp服務(wù)器端源碼示例:

#include <errno.h> 
#include <sys/socket.h> 
#include <netinet/in.h> 
#include <arpa/inet.h> 
#include <stdlib.h> 
#include <string.h> 
#include <netinet/in.h> 
#include <stdio.h> 
#include <unistd.h> 
#include <sys/types.h> 
#include <sys/socket.h> 
 
int main(int argc, char **argv) 
{ 
 printf("server ip: %s/n", argv[1]); 
 printf("server port: %s/n", argv[2]); 
 
 printf("/n service starting.../n/n"); 
 int  socketFd; 
 struct sockaddr_in svrAddr; 
 struct sockaddr_in localAddr; 
 
 socketFd = socket (AF_INET, SOCK_DGRAM, 0); 
 if ( -1 == socketFd ) 
 { 
  perror( "socket:" ); 
  exit(-1); 
 } 
 
 // 設(shè)置地址可復(fù)用 
 int option = 1; 
 setsockopt( socketFd, SOL_SOCKET, SO_REUSEADDR, &option, sizeof(option) ); 
 // 客戶端IP 
 memset(&localAddr, 0, sizeof(localAddr)); 
 localAddr.sin_family = AF_INET; 
 localAddr.sin_addr.s_addr = inet_addr( argv[1]); 
 localAddr.sin_port = htons (atoi(argv[2])); 
 
 int bindResult = bind(socketFd, (struct sockaddr *) &localAddr, sizeof(localAddr)); 
 if ( -1 == bindResult ) 
 { 
  perror( "bind:" ); 
  close(socketFd); 
  exit(-1); 
 } 
 
 // 服務(wù)器IP 
 memset(&svrAddr, 0, sizeof(svrAddr)); 
 svrAddr.sin_family = AF_INET; 
 svrAddr.sin_addr.s_addr = inet_addr( argv[1]); 
 svrAddr.sin_port = htons (atoi(argv[2])); 
 char tempBuff[2048] = {0}; 
 
 for ( ; ; ) 
 { 
  // 接收數(shù)據(jù) 
  struct sockaddr_in fromAddr; 
  memset((char *)&fromAddr, 0, (int)sizeof(fromAddr)); 
  socklen_t fromLen = sizeof(fromAddr); 
  ssize_t result = recvfrom( socketFd, tempBuff, sizeof(tempBuff), 0, (struct sockaddr *)&fromAddr, &fromLen);  
  if ( -1 == result ) 
  { 
   perror("recvfrom:"); 
   continue; 
  } 
  else 
  { 
   printf( "recv data %s successed. data len: %d/n", inet_ntoa(fromAddr.sin_addr), result ); 
   printf( "data:/n"); 
   for ( int i = 0; i < result; i++ ) 
   { 
    printf( "%02x ", tempBuff[i] ); 
    if ( (i+1)%16 == 0 ) 
    { 
     printf( "/n" ); 
    } 
   } 
   printf( "/n" ); 
  } 
   
  // 發(fā)送數(shù)據(jù) 
  result = sendto( socketFd, tempBuff, result, 0, (struct sockaddr*)&fromAddr, sizeof(fromAddr)); 
  if ( -1 == result ) 
  { 
   perror("sendto:"); 
  } 
  else 
  { 
   printf("send data success. data len:%d/n", result ); 
  }   
  sleep( 60 ); 
 } 
 close(socketFd); 
} 

linux下udp客戶端源碼示例:

#include <errno.h> 
#include <sys/socket.h> 
#include <netinet/in.h> 
#include <arpa/inet.h> 
#include <stdlib.h> 
#include <string.h> 
#include <netinet/in.h> 
#include <stdio.h> 
#include <unistd.h> 
#include <sys/types.h> 
#include <sys/socket.h> 
 
typedef struct _NSS_HEADER 
{ 
 unsigned short   ProtocolVersion;  /* 協(xié)議版本信息 */ 
 unsigned short   MsgType;    /* 消息類型 */ 
 unsigned short   TransactionNo;   /* 傳輸編號 */ 
 unsigned short   PacketLength;   /* 數(shù)據(jù)包長度,包括Header */ 
}NSS_HEADER; 
 
int main(int argc, char **argv) 
{ 
 printf("client ip: %s/n", argv[1]); 
 printf("client port: %s/n", argv[2]); 
 printf("server ip: %s/n", argv[3]); 
 printf("server port: %s/n", argv[4]); 
 
 printf("/n service starting.../n/n"); 
 int  socketFd; 
 struct sockaddr_in svrAddr; 
 struct sockaddr_in localAddr; 
 
 socketFd = socket (AF_INET, SOCK_DGRAM, 0); 
 if ( -1 == socketFd ) 
 { 
  perror( "socket:" ); 
  exit(-1); 
 } 
 
 // 設(shè)置地址可復(fù)用 
 int option = 1; 
 setsockopt( socketFd, SOL_SOCKET, SO_REUSEADDR, &option, sizeof(option) ); 
 // 客戶端IP 
 memset(&localAddr, 0, sizeof(localAddr)); 
 localAddr.sin_family = AF_INET; 
 localAddr.sin_addr.s_addr = inet_addr( argv[1]); 
 localAddr.sin_port = htons (atoi(argv[2])); 
 
 int bindResult = bind(socketFd, (struct sockaddr *) &localAddr, sizeof(localAddr)); 
 if ( -1 == bindResult ) 
 { 
  perror( "bind:" ); 
  sleep(10); 
  close(socketFd); 
  exit(-1); 
 } 
 
 // 服務(wù)器IP 
 memset(&svrAddr, 0, sizeof(svrAddr)); 
 svrAddr.sin_family = AF_INET; 
 svrAddr.sin_addr.s_addr = inet_addr( argv[3]); 
 svrAddr.sin_port = htons (atoi(argv[4])); 
 char tempBuff[2048] = {0}; 
 
 // 每分鐘發(fā)送一次數(shù)據(jù) 
 NSS_HEADER hdr; 
 memset( &hdr, 0, sizeof(NSS_HEADER)); 
 for ( ; ; ) 
 { 
  // 發(fā)送數(shù)據(jù) 
  hdr.TransactionNo++; 
  ssize_t result = sendto( socketFd, &hdr, sizeof(NSS_HEADER), 0, (struct sockaddr*)&svrAddr, sizeof(svrAddr)); 
  if ( -1 == result ) 
  { 
   perror("sendto:"); 
  } 
  else 
  { 
   printf("send data success. data len:%d/n", result ); 
  } 
 
  // 接收數(shù)據(jù) 
  struct sockaddr_in fromAddr; 
  memset((char *)&fromAddr, 0, (int)sizeof(fromAddr)); 
  socklen_t fromLen = sizeof(fromAddr); 
  result = recvfrom( socketFd, tempBuff, sizeof(tempBuff), 0, (struct sockaddr *)&fromAddr, &fromLen);  
  if ( -1 == result ) 
  { 
   perror("recvfrom:"); 
  } 
  else 
  { 
   printf( "recv data %s successed. data len: %d/n", inet_ntoa(fromAddr.sin_addr), result ); 
   printf( "data:/n"); 
   for ( int i = 0; i < result; i++ ) 
   { 
    printf( "%02x ", tempBuff[i] ); 
    if ( (i+1)%16 == 0 ) 
    { 
     printf( "/n" ); 
    } 
   } 
   printf("/n"); 
  } 
  sleep( 60 ); 
 } 
 close(socketFd); 
} 

上一篇:希爾排序算法的C語言實(shí)現(xiàn)示例

欄    目:C語言

下一篇:Win10中VC2013安裝Unit test組件出現(xiàn)問題解決方案

本文標(biāo)題:Linux中使用C語言實(shí)現(xiàn)基于UDP協(xié)議的Socket通信示例

本文地址:http://www.jygsgssxh.com/a1/Cyuyan/2404.html

網(wǎng)頁制作CMS教程網(wǎng)絡(luò)編程軟件編程腳本語言數(shù)據(jù)庫服務(wù)器

如果侵犯了您的權(quán)利,請與我們聯(lián)系,我們將在24小時內(nèi)進(jìn)行處理、任何非本站因素導(dǎo)致的法律后果,本站均不負(fù)任何責(zé)任。

聯(lián)系QQ:835971066 | 郵箱:835971066#qq.com(#換成@)

Copyright © 2002-2020 腳本教程網(wǎng) 版權(quán)所有