5.1 基于TCP的服务器端和客户端2
2017-01-19 12:47
483 查看
4.1的Client代码中, 在传输的数据较大时就会出现问题。
服务器端不需要修改,client进行改进:
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#define BUF_SIZE 1024
void error_handling(char *message);
int main(int argc,char *argv[]){
int sock;
struct sockaddr_in serv_addr;
char message[BUF_SIZE];
int str_len,recv_len,recv_cnt;
if(argc != 3){
printf("Usage : %s <IP> <port>\n",argv[0]);
exit(1);
}
sock = socket(PF_INET,SOCK_STREAM,0);
if(sock == -1){
error_handling("socket() error");
}
memset(&serv_addr,0,sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = inet_addr(argv[1]);
serv_addr.sin_port = htons(atoi(argv[2]));
if(connect(sock,(struct sockaddr *)&serv_addr,sizeof(serv_addr)) == -1){
error_handling("connect() error\r\n");
}else{
printf("Connected....");
}
while(1){
printf("Input message(Q to quit):");
fgets(message,BUF_SIZE,stdin);
if(!strcmp(message,"q\n") || !strcmp(message,"Q\n"))
break;
str_len = write(sock,message,strlen(message));
recv_len = 0;
while(recv_len < str_len){
recv_cnt = read(sock,&message[recv_len],BUF_SIZE-1);
if(recv_cnt == -1)
error_handling("read() error!");
recv_len += recv_cnt;
}
message[str_len] = 0;
printf("Message from server : %s \n",message);
}
close(sock);
return 0;
}
void error_handling(char *message){
fputs(message,stderr);
fputs("\n",stderr);
exit(1);
}
执行结果:
alex@alex-VirtualBox:~/Share/Test/tcpip$ ./echo_client2 127.0.0.1 9190
Connected....Input message(Q to quit):hheafaf
Message from server : hheafaf
Input message(Q to quit):affffffffffffffffffffffffffffffffffffffffffffff..
Message from server : affffffffffffffffffffffffffffffffffffffffffffff..
服务器端不需要修改,client进行改进:
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#define BUF_SIZE 1024
void error_handling(char *message);
int main(int argc,char *argv[]){
int sock;
struct sockaddr_in serv_addr;
char message[BUF_SIZE];
int str_len,recv_len,recv_cnt;
if(argc != 3){
printf("Usage : %s <IP> <port>\n",argv[0]);
exit(1);
}
sock = socket(PF_INET,SOCK_STREAM,0);
if(sock == -1){
error_handling("socket() error");
}
memset(&serv_addr,0,sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = inet_addr(argv[1]);
serv_addr.sin_port = htons(atoi(argv[2]));
if(connect(sock,(struct sockaddr *)&serv_addr,sizeof(serv_addr)) == -1){
error_handling("connect() error\r\n");
}else{
printf("Connected....");
}
while(1){
printf("Input message(Q to quit):");
fgets(message,BUF_SIZE,stdin);
if(!strcmp(message,"q\n") || !strcmp(message,"Q\n"))
break;
str_len = write(sock,message,strlen(message));
recv_len = 0;
while(recv_len < str_len){
recv_cnt = read(sock,&message[recv_len],BUF_SIZE-1);
if(recv_cnt == -1)
error_handling("read() error!");
recv_len += recv_cnt;
}
message[str_len] = 0;
printf("Message from server : %s \n",message);
}
close(sock);
return 0;
}
void error_handling(char *message){
fputs(message,stderr);
fputs("\n",stderr);
exit(1);
}
执行结果:
alex@alex-VirtualBox:~/Share/Test/tcpip$ ./echo_client2 127.0.0.1 9190
Connected....Input message(Q to quit):hheafaf
Message from server : hheafaf
Input message(Q to quit):affffffffffffffffffffffffffffffffffffffffffffff..
Message from server : affffffffffffffffffffffffffffffffffffffffffffff..
相关文章推荐
- 基于TCP的服务器端/客户端(一)---------网络编程(linux----C)
- 基于tcp的服务器端和客户端简单版
- 基于TCP的客户端与服务器端之间的通信
- 基于TCP的服务器端/客户端(二)---------网络编程(Linux----C)
- 基于TCP的迭代回声服务器端和客户端
- 第四章 基于TCP的服务器端/客户端(1)
- 关于Python基于TCP的服务器端和客户端编程
- 基于Windows的迭代回声服务器端/客户端(基于TCP的服务器端/客户端)
- 基于TCP/IP的套接字服务器端和客户端编程
- 2017.8.22 用python实现简单基于TCP/IP的客户端与服务器端
- 第五章 基于TCP的服务器端/客户端(2)
- 基于C#的socket编程的TCP异步实现 ,包含服务器端与客户端源代码
- C#基于TCP&UDP实现服务器与多个客户端之间的通信(客户端之间直接通信,不靠服务器端转发消息)
- 基于TCP的客户端,服务器端上传文本文件的功能Demo
- 基于TCP服务器端,客户端的上传任意文件Demo
- 基于TCP的客户端、服务器端socket编程
- 基于TCP/IP的手机聊天游戏(附带源码和解释)之客户端类
- WINDOWS (服务器) 和 DOS(客户端) 网络互连 基于TCP/IP的编程实现
- 基于TCP/IP的手机聊天游戏(附带源码和解释)之服务器端类
- c#中异步基于消息通信的完成端口的TCP-IP协议的组件实现(服务器端-源代码)