代码拉取完成,页面将自动刷新
//
// Created by jxq on 19-7-21.
//
#include <iostream>
#include <stdio.h>
#include <cstring>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
using namespace std;
struct packet
{
int len;
char buf[1024];
};
#define ERR_EXIT(m) \
do \
{ \
perror(m); \
exit(EXIT_FAILURE); \
} while(0);
ssize_t readn(int fd, void *buf, size_t count)
{
size_t nleft = count; // 剩余字节数
ssize_t nread;
char *bufp = (char*) buf;
while (nleft > 0)
{
nread = read(fd, bufp, nleft);
if (nread < 0)
{
if (errno == EINTR)
{
continue;
}
return -1;
} else if (nread == 0)
{
return count - nleft;
}
bufp += nread;
nleft -= nread;
}
return count;
}
ssize_t writen(int fd, const void *buf, size_t count)
{
size_t nleft = count;
ssize_t nwritten;
char* bufp = (char*)buf;
while (nleft > 0)
{
if ((nwritten = write(fd, bufp, nleft)) < 0)
{
if (errno == EINTR)
{
continue;
}
return -1;
}
else if (nwritten == 0)
{
continue;
}
bufp += nwritten;
nleft -= nwritten;
}
return count;
}
int main(int argc, char** argv) {
// 1. 创建套接字
int sockfd;
if ((sockfd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0) {
ERR_EXIT("socket");
}
// 2. 分配套接字地址
struct sockaddr_in servaddr;
memset(&servaddr, 0, sizeof servaddr);
servaddr.sin_family = AF_INET;
servaddr.sin_port = htons(6666);
// servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
servaddr.sin_addr.s_addr = inet_addr("127.0.0.1");
// inet_aton("127.0.0.1", &servaddr.sin_addr);
// 3. 请求链接
if (connect(sockfd, (struct sockaddr *) &servaddr, sizeof servaddr) < 0) {
ERR_EXIT("connect");
}
// 4. 数据交换
// char recvbuf[1024];
// char sendbuf[1024];
struct packet recvbuf;
struct packet sendbuf;
memset(&recvbuf, 0, sizeof recvbuf);
memset(&sendbuf, 0, sizeof sendbuf);
int n = 0;
while (fgets(sendbuf.buf, sizeof sendbuf.buf, stdin) != NULL) // 键盘输入获取
{
n = strlen(sendbuf.buf);
sendbuf.len = htonl(n); // 主机字节序转换为网络字节序
writen(sockfd, &sendbuf, 4+n); // 写入服务器
int ret = readn(sockfd, &recvbuf.len, 4); // 服务器读取
if (ret == -1)
{
ERR_EXIT("read");
}
else if (ret < 4)
{
printf("server close\n");
break;
}
n = ntohl(recvbuf.len);
ret = readn(sockfd, &recvbuf.buf, n);
if (ret == -1)
{
ERR_EXIT("read");
}
else if (ret < n)
{
printf("server close\n");
break;
}
fputs(recvbuf.buf, stdout); // 服务器返回数据输出
// 清空
memset(&recvbuf, 0, sizeof recvbuf);
memset(&sendbuf, 0, sizeof sendbuf);
}
// 5. 断开连接
close(sockfd);
return 0;
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。