Linux环境下1v1 聊天程序

环境:Linux
方式:server Vs client
socket编程典型案例。如果继续弄,要做一个强大的服务器程序,满足多个客户端连接,进行中转。

#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include <netdb.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <sys/socket.h>
int main(int argc,char *argv[]) {
 int sockfd,numbytes;
 char buf[100] = {0};
 char msg[100]={0};
 FILE*fp = NULL ;
 struct hostent *he;
 struct sockaddr_in their_addr;
 int i = 0;
 //将基本名字和地址转换,用户必须输入服务器的名字为参数
 if(argc<2) {
  printf("You should input IP or Name of the server!\n");
  exit(1);
 }
 if((fp = fopen("snd.txt", "r")) == NULL)
 {
 printf("\nCant open snd.txt\n") ;
 exit(0) ;
 } ;
he = gethostbyname(argv[1]);

//建立一个TCP套接口
 if((sockfd = socket(AF_INET,SOCK_STREAM,0))==-1) {
 perror("socket");
 exit(1);
 }

//初始化结构体,连接到服务器的2323端口
 their_addr.sin_family = AF_INET;
 their_addr.sin_port = htons(2323);
 their_addr.sin_addr = *((struct in_addr *)he->h_addr);
 bzero(&(their_addr.sin_zero),8);

//和服务器建立连接,若连接建立失败则直接报错
 if(connect(sockfd,(struct sockaddr *)&their_addr,
 sizeof(struct sockaddr))==-1){
 perror("connect");
 exit(1);
 }

//向服务器发送字符串msg
while(1)
{
 while(1)
 {
  int maxinput = 100 ;
  char *Pmsg = NULL ;
  Pmsg = msg ;
  while(*(Pmsg-1) !='\n')
  {
   maxinput--;
   if(maxinput == 1)
   {
    break;
   }
   scanf("%c",Pmsg++) ;
  }
  break ;
 }
if(send(sockfd,msg,strlen(msg),0)==-1)
  {
   perror("send");
   exit(1);
  }
 memset(msg,0,sizeof(msg)) ;
 if((numbytes = recv(sockfd, buf, 100,0))==-1)
 {
  perror("recv") ;
  exit(1) ;
 }
 printf("\nserver said:%s\nclient said:",buf);
 memset(buf ,0 , sizeof(buf)) ;
}
close(sockfd);
 return 0;
}
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <sys/wait.h>
void showClientInf(struct sockaddr_in client_addr) {
  printf("\nThe IP of client is:%s",inet_ntoa(client_addr.sin_addr));
  printf("\nThe Port of client is:%d\n",ntohs(client_addr.sin_port));
}
int main() {
 int sockfd,new_fd;
 struct sockaddr_in my_addr;
 struct sockaddr_in their_addr;
 int sin_size;
 char buff[100] = {0};
char snd_data[100] ={0} ;
 char *p = NULL ;
 int numbytes;

//建立TCP套接口
if((sockfd = socket(AF_INET,SOCK_STREAM,0))==-1) {
  perror("socket");
  exit(1);
 }

//初始化结构体,并绑定2323端口
 my_addr.sin_family = AF_INET;
 my_addr.sin_port = htons(2323);
 my_addr.sin_addr.s_addr = INADDR_ANY;
 bzero(&(my_addr.sin_zero),8);

//绑定套接口
 if(bind(sockfd,(struct sockaddr *)&my_addr,sizeof(struct sockaddr))==-1)
 {
  perror("bind");
  exit(1);
 }

//创建监听套接口
 if(listen(sockfd,10)==-1) {
  perror("listen");
  exit(1);
 }
 printf("server is run...\n");

//等待连接
 while(1) {
  sin_size = sizeof(struct sockaddr_in);

//如果建立连接,将产生一个全新的套接字,their_fd存储发送方的信息
  //一个套接字与客户端保持控制连接,新套接字与客户端传递、接受信息
  if((new_fd = accept(sockfd,(struct sockaddr *)
  &their_addr,&sin_size))==-1)
  {
   perror("accept");
   exit(1);
  }

//显示客户端信息
  showClientInf(their_addr);

//生成一个子进程来完成和客户端的会话,父进程继续监听
  if(!fork())
{
  while(1)
  {

//读取客户端发来的信息
  //只能用sizeof取buff的大小,因为buff还没初始化,用strlen很容易碰到'\0'
   memset(buff,0 , sizeof(buff)) ;
   if(numbytes= recv(new_fd,buff,sizeof(buff),0)!=0)
   {
    printf("\nclient said :%s\nserver:",buff) ;
}
   while(1)
 {
  memset(snd_data, 0 , sizeof(snd_data));
  char *p = snd_data ;
  while(*(p-1)!= '\n')
  {
   scanf("%c",p++) ;
  }
  break ;
 }

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/wzwwdj.html