【发布时间】:2018-11-28 13:48:31
【问题描述】:
我创建了一个用于套接字通信的短类,并希望多次向同一设备发送和接收(这里以 www.kernel.org 为例,在我的例子中,它是一个通过以太网连接的传感器)。 通信使用 HTTP,我用“PacketSender”测试了设备,它工作正常。
第一次尝试我发送请求并获得预期的响应。然后我想循环它,但是我可以发送尽可能多和不同的请求,但我什么也得不到。
这是我的课(我只把它作为草稿留在了 H 文件中,当它工作时会使它更体面)
#ifndef SOCKETCLASS_H_INCLUDED
#define SOCKETCLASS_H_INCLUDED
#include <windows.h>
#include <winsock2.h>
#include <stdio.h>
#pragma comment(lib, "Ws2_32.lib")
class WinSocket{
private:
SOCKET s;
long rc;
int Status = 0;
int PackageSize = 10;
public:
WinSocket(){
rc=startWinsock();
if(rc!=0){
printf("Error: startWinsock failed, ErCode %d \n",int(rc));
Status= -1;
}else{
printf("Winsock ready!\n");
}
}
int openSocket(char *IPv4, int Port){
SOCKADDR_IN addr;
int rc = 0;
s = socket(AF_INET,SOCK_STREAM,0);
if(s==INVALID_SOCKET){
printf("Error: Socket could not be created! ErCode: %d\n",WSAGetLastError());
return 1;
}else{
printf("Socket created\n");
}
memset(&addr,0,sizeof(SOCKADDR_IN));
addr.sin_family=AF_INET;
addr.sin_port=htons(80);
addr.sin_addr.s_addr=inet_addr(IPv4);
rc=connect(s,(SOCKADDR*)&addr,sizeof(SOCKADDR));
if(rc==SOCKET_ERROR){
printf("Error: Failed to connect, ErCode: %d\n",WSAGetLastError());
return 1;
}else{
printf("Connected to %s...\n",IPv4);
}
return 0;
}
int sendPackage(char *Buffer, int BufferSize){
int i,j;
int result;
int Pointer = 0;
char *Package;
Package = new char[PackageSize];
for(i = 0; i < BufferSize; i+=PackageSize){
for(j = 0; j < PackageSize; j++){
Package[j] = Buffer[Pointer];
Pointer++;
if(BufferSize <= Pointer){
break;
}
}
result = send(s,Package,PackageSize,0);
if(result<0){
printf("Error Occured!\n");
return -1;
}
}
delete[]Package;
return 0;
}
int readLine(char *Buffer, int *BufferSize){
int MAX_BUFFERSIZE = 1024;
int res = 0;
char B[1];
*BufferSize = 0;
int Pointer = 0;
for(int i=0;i<MAX_BUFFERSIZE;i++){
res = recv(s,B,1,0);
if(res > 0){
if(B[0]!='\n'){
//printf("%d;%s\n",res,B);
Buffer[Pointer] = B[0];
Pointer += 1;
}else{
Buffer[Pointer]='\n';
*BufferSize = Pointer;
return 0;
}
}else if(res == 0){
return 1;
}else{
return -1;
}
}
return 0;
}
int startWinsock(void){
WSADATA wsa;
return WSAStartup(MAKEWORD(2,0),&wsa);
}
~WinSocket(){
closesocket(s);
}
};
#endif // SOCKETCLASS_H_INCLUDED
作为主要功能,我使用以下代码:
#include <stdio.h>
#include "SocketClass.h"
int main(){
char buf[256];
int i,j;
int requestSize = 100;
char request[100];
char Buf[1024];
int BufferSize = 1;
WinSocket S;
S.openSocket("147.75.44.153",80);
for(int l = 0; l<10; l++){
printf("Loop %d\n",l);
printf("Sending: ");
requestSize = sprintf(request,"GET /faq.html HTTP/1.1\r\nHost: www.kernel.org\r\nConnection: close\r\n\r\n");
printf("%d Bytes: \n",requestSize);
S.sendPackage(request,100);
for(j= 0; j < requestSize; j ++){
printf("%c",request[j]);
}
printf("\n");
Sleep(500);
printf("Waiting for responset...\n");
while(BufferSize!=0){
printf("Received: ");
S.readLine(Buf, &BufferSize);
printf("%d Bytes: \n",BufferSize);
for(int i=0;i<BufferSize;i++){
printf("%c",Buf[i]);
}
printf("\n");
}
if(BufferSize==0){
printf("\nNothing more received...\n");
}
printf("Repeat!\n");
Sleep(5000);
}
printf("Finished...\n");
printf("Press ENTER to continue...\n");
getchar();
return 0;
}
我测试了每个循环打开和关闭套接字。这有时是有效的(所以有没有我没有提到的未定义指针?),但我想要长时间的连接。
我不明白的是,为什么我可以发送多次,但只能在第一次发送任何数据时接收。
我正在使用 Windows 7 和 mingw(GNU GCC 编译器)。
感谢您的帮助。
【问题讨论】: