C語(yǔ)言編寫(xiě)基于TCP和UDP協(xié)議的Socket通信程序示例

來(lái)源：本站原創(chuàng)|時(shí)間：2020-01-10|欄目：C語(yǔ)言|點(diǎn)擊：次

Tcp多線(xiàn)程服務(wù)器和客戶(hù)端程序
服務(wù)器程序:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#define PORT 8082
#define BUFSIZE 512
char buf[BUFSIZE+1];

void* fun(void* x)
{
    //printf("enter thread!\r\n");
    int new_fd=*((int*)x);
  while(1)
    {
    int z=read(new_fd,buf,BUFSIZE);//第 6 步 讀取套接字
  if(z==0){printf("client close !");break;};
  buf[z]='\0';
  printf("%s\r\n",buf);//打印
  };
}
int newfd[512];
int inewfd=0;
int main()
{
  //第 1 步 創(chuàng)建套接字
  int sockfd=socket(AF_INET,SOCK_STREAM,0);
  //第 2 步 設(shè)置地址結(jié)構(gòu)體
  struct sockaddr_in svraddr;
  svraddr.sin_family=AF_INET;//使用 internet 協(xié)議
  svraddr.sin_port=htons(PORT);
  inet_aton("0.0.0.0",&svraddr.sin_addr);
  //第 3 步 綁定
  int ret=bind(sockfd,(struct sockaddr*)&svraddr,sizeof(svraddr));
    if(ret<0){printf("error bind!\r\n");exit(-1);};
  //第 4 步 監(jiān)聽(tīng)
  listen(sockfd,128);
  while(1)
  {
  newfd[inewfd++]=accept(sockfd,NULL,NULL); //第 5 步 接收
  pthread_t ntid;
    pthread_create(&ntid,NULL,fun,(void*)&(newfd[inewfd-1])); 
  }
}

注意：

gcc server.c -o server -lpthread

客戶(hù)端程序 cli.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#define PORT 8082
#define BUFSIZE 512
char buf[BUFSIZE+1];
int main()
{
  //第 1 步 創(chuàng)建一個(gè)體套接字
  int sockfd=socket(AF_INET,SOCK_STREAM,0);
  //第 2 步 設(shè)置 addr 結(jié)構(gòu)體
  struct sockaddr_in svraddr;
  svraddr.sin_family=AF_INET;//使用 internet 協(xié)議
  svraddr.sin_port=htons(PORT);
  inet_aton("127.0.0.1",&svraddr.sin_addr);
  //第 3 步 連接服務(wù)器
  connect(sockfd,(struct sockaddr*)&svraddr,sizeof(svraddr));
  while(1)
  {
  scanf("%s",buf);
  write(sockfd,buf,strlen(buf)); //第 4 步 向套接字中寫(xiě)入字符串
  }
}

Udp的服務(wù)器程序和客戶(hù)端程序

服務(wù)器程序:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#define PORT 8082
#define BUFSIZE 512
char buf[BUFSIZE+1];
int main()
{
  //第 1 步 創(chuàng)建套接字
  int sockfd=socket(AF_INET,SOCK_DGRAM,0);
  //第 2 步 設(shè)置地址結(jié)構(gòu)體
  struct sockaddr_in svraddr;
  svraddr.sin_family=AF_INET;//使用 internet 協(xié)議
  svraddr.sin_port=htons(PORT);
  inet_aton("0.0.0.0",&svraddr.sin_addr);
  //第 3 步 綁定
  int ret=bind(sockfd,(struct sockaddr*)&svraddr,sizeof(svraddr));
  if(ret<0){printf("cannot bind!\r\n");exit(-1);};
  while(1)
  {
        struct sockaddr_in cli;
        int len=sizeof(cli);
    int z=recvfrom(sockfd,buf,BUFSIZE,0,(struct sockaddr*)&cli,&len);//第 6 步 讀取套接字  
    buf[z]='\0';
    printf("%s\r\n",buf);//打印
  }

}

客戶(hù)端程序 cli.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#define PORT 8082
#define BUFSIZE 512
char buf[BUFSIZE+1];
int main()
{
  //第 1 步 創(chuàng)建一個(gè)體套接字
  int sockfd=socket(AF_INET,SOCK_DGRAM,0);
  //第 2 步 設(shè)置 addr 結(jié)構(gòu)體
  struct sockaddr_in svraddr;
  svraddr.sin_family=AF_INET;//使用 internet 協(xié)議
  svraddr.sin_port=htons(PORT);
  inet_aton("127.0.0.1",&svraddr.sin_addr);
  //第 3 步 連接服務(wù)器
  //connect(sockfd,(struct sockaddr*)&svraddr,sizeof(svraddr));
  while(1)
  {
  scanf("%s",buf);
  sendto(sockfd,buf,strlen(buf),0,(struct sockaddr*)&svraddr,sizeof(svraddr)); //第 4 步 向套接字中寫(xiě)入字符串
  }
}

上一篇：編寫(xiě)C++程序使DirectShow進(jìn)行視頻捕捉

欄目：C語(yǔ)言

下一篇：C++中實(shí)現(xiàn)隊(duì)列類(lèi)鏈?zhǔn)酱鎯?chǔ)與棧類(lèi)鏈?zhǔn)酱鎯?chǔ)的代碼示例

本文標(biāo)題：C語(yǔ)言編寫(xiě)基于TCP和UDP協(xié)議的Socket通信程序示例

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

更多C語(yǔ)言

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

C語(yǔ)言

C語(yǔ)言編寫(xiě)基于TCP和UDP協(xié)議的Socket通信程序示例

您可能感興趣的文章

閱讀排行

本欄相關(guān)

隨機(jī)閱讀