From e88a6656834864dd98da26118fe37d059b276537 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期日, 24 七月 2022 18:02:14 +0800
Subject: [PATCH] '代码完善'
---
app/SocketManager.cpp | 18 ++++++++++--------
1 files changed, 10 insertions(+), 8 deletions(-)
diff --git a/app/SocketManager.cpp b/app/SocketManager.cpp
index 4e61e05..98621bb 100644
--- a/app/SocketManager.cpp
+++ b/app/SocketManager.cpp
@@ -10,7 +10,10 @@
void* SocketManager::callbackContext;
+string SocketManager::ADDR;
+
SocketManager::SocketManager(ActionCallback callback, void* context) {
+
init(callback,context);
}
@@ -103,12 +106,11 @@
}
void SocketManager::init(ActionCallback callback, void* contex) {
-
actionCallback = callback;
callbackContext = contex;
clientaddr.sin_family = AF_INET;
clientaddr.sin_port = htons(PORT);
- clientaddr.sin_addr.S_un.S_addr = inet_addr(ADDR);
+ clientaddr.sin_addr.S_un.S_addr = inet_addr(ADDR.c_str());
//建立9个连接,前8个为数据传输通道，后一个为命令传输通道
sockClients.clear();
for (int i = 0;i < CHANNEL_NUM;i++)
@@ -199,28 +201,28 @@
}
-BOOL SocketManager::sendMsg(const char* msg) {
+string SocketManager::sendMsg(const char* msg) {
WSADATA wsd;
WSAStartup(MAKEWORD(2, 2), &wsd);
SOCKET m_SockClient;
m_SockClient = socket(AF_INET, SOCK_STREAM, 0);
sockaddr_in clientaddr;
clientaddr.sin_family = AF_INET;
- clientaddr.sin_port = htons(9001);
- clientaddr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
+ clientaddr.sin_port = htons(PORT);
+ clientaddr.sin_addr.S_un.S_addr = inet_addr(ADDR.c_str());
connect(m_SockClient, (sockaddr*)&clientaddr, sizeof(clientaddr));
- char buffer[64];
+ char buffer[1024];
int result = send(m_SockClient, msg, strlen(msg), 0);
if (result < 0) {
throw string("发送失败");
}
- int num = recv(m_SockClient, buffer, 64, 0);
+ int num = recv(m_SockClient, buffer, 1024, 0);
closesocket(m_SockClient);
if (num < 0) {
throw string("未接收到信息");
}
- return 1;
+ return string(buffer);
}
--
Gitblit v1.8.0