C++写SOCKET聊天程序，客户端用win32写，出现了问题
我在用C++写SOCKET聊天程序时，客户端用了win32做界面，点击发送按钮时，却没有发送，不知道是得不到文本，还是什么线程之类的问题
客户端图：
测试用的客户端截图：
这是客户端：
#define _WINSOCK_DEPRECATED_NO_WARNINGS
// Client.cpp : 定义应用程序的入口点。
//
#include "framework.h"
#include "Client.h"
#include <stdio.h>
#include <iostream>
#include <string.h>
using namespace std;
#define MAX_LOADSTRING 100
// Your code
// 全局变量:
HINSTANCE hInst; // 当前实例
WCHAR szTitle[MAX_LOADSTRING]; // 标题栏文本
WCHAR szWindowClass[MAX_LOADSTRING]; // 主窗口类名
// 此代码模块中包含的函数的前向声明:
ATOM MyRegisterClass(HINSTANCE hInstance);
BOOL InitInstance(HINSTANCE, int);
LRESULT CALLBACK WndProc(HWND, UINT, WPARAM, LPARAM);
INT_PTR CALLBACK About(HWND, UINT, WPARAM, LPARAM);
SOCKET serverSocket;
SOCKADDR_IN addr = { 0 };
char ip[15];
int len = 5;
bool sm;
bool smip;
char MessageText[120];
HWND hwndButtonSendMessage;
HWND hwndInput = NULL;
HWND hWnd;
/******************************************************************************************
Function: ConvertLPWSTRToLPSTR
Description: LPWSTR转char*
Input: lpwszStrIn:待转化的LPWSTR类型
Return: 转化后的char*类型
*******************************************************************************************/
char* CharXtoLPWSTR(LPWSTR lpwszStrIn)
{
LPSTR pszOut = NULL;
try
{
if (lpwszStrIn != NULL)
{
int nInputStrLen = wcslen(lpwszStrIn);
// Double NULL Termination
int nOutputStrLen = WideCharToMultiByte(CP_ACP, 0, lpwszStrIn, nInputStrLen, NULL, 0, 0, 0) + 2;
pszOut = new char[nOutputStrLen];
if (pszOut)
{
memset(pszOut, 0x00, nOutputStrLen);
WideCharToMultiByte(CP_ACP, 0, lpwszStrIn, nInputStrLen, pszOut, nOutputStrLen, 0, 0);
}
}
}
catch (std::exception e)
{
}
return pszOut;
}
LPWSTR LPWSTRtoCharX(char* str)
{
int num = MultiByteToWideChar(0, 0, str, -1, NULL, 0);
wchar_t* wide = new wchar_t[num];
MultiByteToWideChar(0, 0, str, -1, wide, num);
return wide;
}
void initTCP()
{
int r = 0;
LPCWSTR err;
WSADATA wsaData;
WSAStartup(MAKEWORD(2, 2), &wsaData);
if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2)
{
}
serverSocket = socket(AF_INET, SOCK_STREAM, 0);
if (SOCKET_ERROR == serverSocket)
{
}
SOCKADDR_IN addr = { 0 };
addr.sin_family = AF_INET;
addr.sin_addr.S_un.S_addr = inet_addr("192.168.1.105");
addr.sin_port = htons(9527);
r = connect(serverSocket, (sockaddr*)&addr, sizeof(addr));
if (r == SOCKET_ERROR)
{
int e = WSAGetLastError();
LPTSTR lpsz = new TCHAR[200];
_itow_s(e, lpsz, 100, 10);
MessageBox(NULL, lpsz, NULL, NULL);
delete lpsz;
}
}
void meSend(int idx)
{
while (1)
{
char buff[50];
if (sm == true)
{
GetWindowText(hwndInput, LPWSTRtoCharX(MessageText), GetWindowTextLength(hwndInput));
MessageBox(NULL, LPWSTRtoCharX(MessageText), NULL, NULL);
}
}
}
void meRecv(int idx)
{
int r;
char temp[600];
PAINTSTRUCT ps;
HDC hdc = BeginPaint(hWnd, &ps);
while (1)
{
r = recv(serverSocket, temp, 59, NULL);
if (r > 0)
{
temp[r] = 0;
len += 5;
TextOut(hdc, 10, len * 20, LPWSTRtoCharX(temp), 600);
sm = false;
}
}
EndPaint(hWnd, &ps);
}
int APIENTRY wWinMain(_In_ HINSTANCE hInstance,
_In_opt_ HINSTANCE hPrevInstance,
_In_ LPWSTR lpCmdLine,
_In_ int nCmdShow)
{
initTCP();
UNREFERENCED_PARAMETER(hPrevInstance);
UNREFERENCED_PARAMETER(lpCmdLine);
// TODO: 在此处放置代码。
// 初始化全局字符串
LoadStringW(hInstance, IDS_APP_TITLE, szTitle, MAX_LOADSTRING);
LoadStringW(hInstance, IDC_CLIENT, szWindowClass, MAX_LOADSTRING);
MyRegisterClass(hInstance);
// 执行应用程序初始化:
if (!InitInstance (hInstance, nCmdShow))
{
return FALSE;
}
HACCEL hAccelTable = LoadAccelerators(hInstance, MAKEINTRESOURCE(IDC_CLIENT));
MSG msg;
// 主消息循环:
while (GetMessage(&msg, nullptr, 0, 0))
{
if (!TranslateAccelerator(msg.hwnd, hAccelTable, &msg))
{
TranslateMessage(&msg);
DispatchMessage(&msg);
}
}
return (int) msg.wParam;
}
//
// 函数: MyRegisterClass()
//
// 目标: 注册窗口类。
//
ATOM MyRegisterClass(HINSTANCE hInstance)
{
WNDCLASSEXW wcex;
wcex.cbSize = sizeof(WNDCLASSEX);
wcex.style = CS_HREDRAW | CS_VREDRAW;
wcex.lpfnWndProc = WndProc;
wcex.cbClsExtra = 0;
wcex.cbWndExtra = 0;
wcex.hInstance = hInstance;
wcex.hIcon = LoadIcon(hInstance, MAKEINTRESOURCE(IDI_CLIENT));
wcex.hCursor = LoadCursor(nullptr, IDC_ARROW);
wcex.hbrBackground = (HBRUSH)(COLOR_WINDOW+1);
wcex.lpszMenuName = MAKEINTRESOURCEW(IDC_CLIENT);
wcex.lpszClassName = szWindowClass;
wcex.hIconSm = LoadIcon(wcex.hInstance, MAKEINTRESOURCE(IDI_SMALL));
return RegisterClassExW(&wcex);
}
//
// 函数: InitInstance(HINSTANCE, int)
//
// 目标: 保存实例句柄并创建主窗口
//
// 注释:
//
// 在此函数中，我们在全局变量中保存实例句柄并
// 创建和显示主程序窗口。
//
BOOL InitInstance(HINSTANCE hInstance, int nCmdShow)
{
hInst = hInstance; // 将实例句柄存储在全局变量中
hWnd = CreateWindowW(szWindowClass, szTitle, WS_OVERLAPPEDWINDOW | WS_VSCROLL,
CW_USEDEFAULT, 0, CW_USEDEFAULT, 0, nullptr, nullptr, hInstance, nullptr);
if (!hWnd)
{
return FALSE;
}
ShowWindow(hWnd, nCmdShow);
UpdateWindow(hWnd);
return TRUE;
}
//
// 函数: WndProc(HWND, UINT, WPARAM, LPARAM)
//
// 目标: 处理主窗口的消息。
//
// WM_COMMAND - 处理应用程序菜单
// WM_PAINT - 绘制主窗口
// WM_DESTROY - 发送退出消息并返回
//
//
LRESULT CALLBACK WndProc(HWND hWnd, UINT message, WPARAM wParam, LPARAM lParam)
{
switch (message)
{
case WM_CREATE:
{
hwndButtonSendMessage = CreateWindow(TEXT("Button"), TEXT("发送文本"), WS_VISIBLE | WS_CHILD | BS_PUSHBUTTON, 120, 20, 120, 50, hWnd, (HMENU)IDB_SENDTEXT, ((LPCREATESTRUCT)lParam)->hInstance, NULL);
hwndInput = CreateWindow(TEXT("edit"), NULL,
WS_CHILD | WS_VISIBLE | WS_VSCROLL | WS_HSCROLL | WS_BORDER |
ES_LEFT | ES_MULTILINE | ES_AUTOHSCROLL | ES_AUTOVSCROLL,
20, 20, 100, 50,
hWnd, (HMENU)1, ((LPCREATESTRUCT)lParam)->hInstance, NULL);
break;
}
case WM_GETTEXT:
CreateThread(NULL, NULL, (LPTHREAD_START_ROUTINE)meSend, NULL, NULL, NULL);
break;
case WM_COMMAND:
{
int wmId = LOWORD(wParam);
// 分析菜单选择:
switch (wmId)
{
case IDM_ABOUT:
DialogBox(hInst, MAKEINTRESOURCE(IDD_ABOUTBOX), hWnd, About);
break;
case IDM_EXIT:
DestroyWindow(hWnd);
break;
case IDB_SENDTEXT:
sm = true;
break;
case IDB_OKIP:
smip = true;
break;
default:
return DefWindowProc(hWnd, message, wParam, lParam);
}
}
break;
case WM_PAINT:
{
// TODO: 在此处添加使用 hdc 的任何绘图代码...
CreateThread(NULL, NULL, (LPTHREAD_START_ROUTINE)meRecv, NULL, NULL, NULL);
}
break;
case WM_DESTROY:
PostQuitMessage(0);
break;
default:
return DefWindowProc(hWnd, message, wParam, lParam);
}
return 0;
}
// “关于”框的消息处理程序。
INT_PTR CALLBACK About(HWND hDlg, UINT message, WPARAM wParam, LPARAM lParam)
{
UNREFERENCED_PARAMETER(lParam);
switch (message)
{
case WM_INITDIALOG:
return (INT_PTR)TRUE;
case WM_COMMAND:
if (LOWORD(wParam) == IDOK || LOWORD(wParam) == IDCANCEL)
{
EndDialog(hDlg, LOWORD(wParam));
return (INT_PTR)TRUE;
}
break;
}
return (INT_PTR)FALSE;
}
这是测试用的客户端：
#define _WINSOCK_DEPRECATED_NO_WARNINGS
#include <stdio.h>
#include <iostream>
#include <winsock2.h>
#include <windows.h>
#include <Ws2tcpip.h>
#pragma comment (lib,"ws2_32.lib")
/* run this program using the console pauser or add your own getch, system("pause") or input loop */
SOCKET serverSocket;
char IP[10] = "127.0.0.1";
void mySend(int idx)
{
while (1)
{
char buff[50];
scanf_s("%s", buff);
send(serverSocket, buff, strlen(buff), NULL);
}
}
int main(int argc, char** argv) {
printf_s("此为局域网版本，你的服务器IP：");
scanf_s("%s", IP);
int r = 0;
WSADATA wsaData;
WSAStartup(MAKEWORD(2, 2), &wsaData);
if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2)
{
printf("确定网络协议版本失败：%d\n", GetLastError());
}
serverSocket = socket(AF_INET, SOCK_STREAM, 0);
if (SOCKET_ERROR == serverSocket)
{
printf("创建socket失败：%d\n", GetLastError());
}
SOCKADDR_IN addr = { 0 };
addr.sin_family = AF_INET;
addr.sin_addr.S_un.S_addr = inet_addr(IP);
addr.sin_port = htons(9527);
r = connect(serverSocket, (sockaddr*)&addr, sizeof(addr));
if (r == SOCKET_ERROR)
{
int e = WSAGetLastError();
LPTSTR lpsz = new TCHAR[200];
_itow_s(e, lpsz, 100, 10);
MessageBox(NULL, lpsz, NULL, NULL);
delete lpsz;
}
CreateThread(NULL, NULL, (LPTHREAD_START_ROUTINE)mySend, NULL, NULL, NULL);
char temp[60];
while (1)
{
r = recv(serverSocket, temp, 59, NULL);
if (r > 0)
{
temp[r] = 0;
printf(">>%s\n", temp);
}
}
return 0;
}
服务端
#define _WINSOCK_DEPRECATED_NO_WARNINGS
#include <stdio.h>
#include <iostream>
#include <winsock2.h>
#include <windows.h>
#include <Ws2tcpip.h>
#pragma comment (lib,"ws2_32.lib")
/* run this program using the console pauser or add your own getch, system("pause") or input loop */
#define NUM 1024
SOCKET clientSocket[NUM];
int count = 0;
char IP[10] = "127.0.0.1";
void tongxin(int idx)
{
char buff[560];
char temp[600] = { 0 };
int r;
while (1)
{
r = recv(clientSocket[idx], buff, 79, NULL);
if (r > 0)
{
buff[r] = 0;
printf("%d", count);
printf(">>%s\n", buff);
memset(temp, 0, 80);
sprintf_s(temp, "%d:%s\n", idx, buff);
for (int i = 0; i < count; i++)
{
send(clientSocket[i], temp, strlen(temp), NULL);
printf("<<%s\n", temp);
}
}
}
}
int main(int argc, char** argv) {
printf_s("此为局域网版本，你的内网IP：");
scanf_s("%s", IP);
WSADATA wsaData;
WSAStartup(MAKEWORD(2, 2), &wsaData);
if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2)
{
printf("确定网络协议版本失败：%d\n", GetLastError());
}
printf("确定网络协议版本成功\n");
SOCKET serverSocket = socket(AF_INET, SOCK_STREAM, 0);
if (SOCKET_ERROR == serverSocket)
{
printf("创建socket失败：%d\n", GetLastError());
}
printf("创建socket成功\n");
SOCKADDR_IN addr = { 0 };
addr.sin_family = AF_INET;
addr.sin_addr.S_un.S_addr = inet_addr(IP);
addr.sin_port = htons(9527);
SOCKADDR_IN caddr = { 0 };
int csize = sizeof(caddr);
int r = bind(serverSocket, (sockaddr*)&addr, sizeof addr);
if (-1 == r)
{
printf("绑定失败：%d\n", GetLastError());
}
printf("绑定成功\n");
r = listen(serverSocket, 10);
if (-1 == r)
{
printf("监听失败：%d\n", GetLastError());
}
printf("监听成功\n");
for (int i = 0; i < NUM; i++)
{
clientSocket[i] = accept(serverSocket, (sockaddr*)NULL, NULL);
if (-1 != r)
{
printf("一个客户端链接\n");
count += 1;
}
CreateThread(NULL, NULL, (LPTHREAD_START_ROUTINE)tongxin, (LPVOID)i, NULL, NULL);
}
return 0;
}
- 帮你找了个相似的问题, 你可以看下: https://ask.csdn.net/questions/188738
- 您还可以看一下 张立铜老师的C++ 百万并发网络通信引擎架构与实现 （Socket、全栈、跨平台） Version 1.0课程中的 18年版_云测试2_Windows_C100K_十万活跃用户小节, 巩固相关知识点