C/C++TCP套接字服务器读取
C/C++ TCP Socket Server Read
我想创建一个服务器和客户端,在linux上运行,这样
- 连接已建立
- 客户端向服务器发送消息
- 服务器向客户端发送响应
- 端部连接
使用http://www.thegeekstuff.com/2011/12/c-socket-programming/,这就是我想到的。
TCPSockets.cpp
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <sys/types.h>
#include <time.h>
#include <iostream>
int createConnection(char *ipaddr)
{
int sockfd = 0;
struct sockaddr_in serv_addr;
if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
{
printf("n Error : Could not create socket n");
return -1;
}
memset(&serv_addr, '0', sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_port = htons(5000);
if(inet_pton(AF_INET, ipaddr, &serv_addr.sin_addr)<=0)
{
printf("n inet_pton error occuredn");
return -1;
}
if( connect(sockfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0)
{
printf("n Error : Connect Failed n");
return -1;
}
return sockfd;
}
void receiveMessage(int sockfd)
{
int n = 0;
char recvBuff[1024];
memset(recvBuff, '0',sizeof(recvBuff));
while ( (n = read(sockfd, recvBuff, sizeof(recvBuff)-1)) > 0)
{
std::cout<<"recvBuff="<<recvBuff<<std::endl;
recvBuff[n] = 0;
if(fputs(recvBuff, stdout) == EOF)
{
printf("n Error : Fputs errorn");
}
}
if(n < 0)
{
printf("n Read error n");
}
}
int createListeningSocket()
{
int listenfd = 0;
struct sockaddr_in serv_addr;
listenfd = socket(AF_INET, SOCK_STREAM, 0);
memset(&serv_addr, '0', sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
serv_addr.sin_port = htons(5000);
bind(listenfd, (struct sockaddr*)&serv_addr, sizeof(serv_addr));
listen(listenfd, 10);
return listenfd;
}
void sendMessage(int connfd, char * format) {
char sendBuff[1025];
memset(sendBuff, '0', sizeof(sendBuff));
snprintf(sendBuff, sizeof(sendBuff), format);
write(connfd, sendBuff, strlen(sendBuff));
}
服务器.cpp
#include "TCPSockets.cpp"
int main(int argc, char *argv[]) {
std::cout<<"Creating socket..."<<std::endl;
int listeningSocketDescriptor = createListeningSocket();
std::cout<<"Socket created."<<std::endl;
std::cout<<"Waiting for connection..."<<std::endl;
int clientSocketDescriptor = accept(listeningSocketDescriptor, (struct sockaddr*)NULL, NULL);
std::cout<<"Connection made."<<std::endl;
std::cout<<"Waiting for message..."<<std::endl;
receiveMessage(listeningSocketDescriptor);
std::cout<<"Message received."<<std::endl;
std::cout<<"Sending message..."<<std::endl;
sendMessage(clientSocketDescriptor, "From server!");
std::cout<<"Message sent."<<std::endl;
std::cout<<"Closing client socket..."<<std::endl;
close(clientSocketDescriptor);
std::cout<<"Client socket closed."<<std::endl;
close(listeningSocketDescriptor);
return 0;
}
客户端.cpp
#include "TCPSockets.cpp"
int main(int argc, char *argv[]) {
if(argc != 2)
{
printf("n Usage: %s <ip of server> n",argv[0]);
return 1;
}
std::cout<<"Creating connection..."<<std::endl;
int socketDescriptor = createConnection(argv[1]);
if (socketDescriptor < 0)
{
return 1;
}
std::cout<<"Connection created."<<std::endl;
std::cout<<"Sending message..."<<std::endl;
sendMessage(socketDescriptor, "From client!");
std::cout<<"Message sent."<<std::endl;
std::cout<<"Waiting for response..."<<std::endl;
receiveMessage(socketDescriptor);
std::cout<<"Response received."<<std::endl;
return 0;
}
除了服务器接收消息外,其他一切都正常工作。我做错了什么?
您的代码是:
int clientSocketDescriptor = accept(listeningSocketDescriptor,
(struct sockaddr*)NULL, NULL);
receiveMessage(listeningSocketDescriptor);
但是您应该读取从accept()
:返回的客户端套接字描述符中的字节
int cs = accept(listeningSocketDescriptor, (struct sockaddr*)NULL, NULL);
receiveMessage(cs);
而不是来自CCD_ 2。
相关文章:
- TCP 服务器的异步读取使用 boost::asio 打印客户端套接字发送的数据
- 为 Sql 服务器实现 odbc 包装器.将数据库数据读取为字符或要求驱动程序将数据转换为 C 类型
- 如何使用软化工具包从 OPC UA 服务器异步读取操作回调中的数据值响应中获取 NodeId 详细信息
- 使用 Broadcast 发出的从节点服务器发送的数据不能被 C++ 套接字 IO 客户端读取
- 如何使用 GRPC c++ 读取异步服务器端流
- 如何使客户端在将数据写入 C++ 管道之前检查服务器是否完成了从管道的读取操作
- Qt TCP服务器不从客户端读取数据
- 在 c++ 服务器上实时读取输入
- 无法在java(客户端)的套接字上正确写入数据(类),也无法在c ++(服务器)上读取数据(类)
- 直接从Uwebsockets服务器读取Uint8array
- 无法从Web服务器读取UTF-8缓冲区
- Boost ASIO async_read 没有从服务器读取数据
- C/C++TCP套接字服务器读取
- 为什么在读取非HTTP服务器的套接字时需要异步IO
- 如何读取 HTTP 请求(HTTP 代理服务器)
- C/C++服务器,通过stdin/stdout与客户端通信(阻塞stdin,直到读取了大量字节)
- 无法使用 Java 服务器的提升C++客户端读取
- 从标准输入读取输入,并准备接收来自服务器的广播
- C 服务器和 Java 客户端.如何读取完整字符串
- UDP 客户端/服务器发送数据但无法读取