MFC中socket多线程实现

在MFC中使用Socket多线程实现可以实现并发的网络通信。下面是一个简单的示例代码，演示了如何在MFC中使用Socket和多线程来实现服务器和客户端之间的通信：

服务器端代码（CMyServerDlg.cpp）：

// 头文件中添加以下内容
#include <afxsock.h>

// 定义一个自定义类继承自CWinThread，用于处理客户端连接的线程
class CClientThread : public CWinThread
{
	DECLARE_DYNCREATE(CClientThread)

public:
	virtual BOOL InitInstance();
	virtual int ExitInstance();

protected:
	DECLARE_MESSAGE_MAP()
};

IMPLEMENT_DYNCREATE(CClientThread, CWinThread)

BEGIN_MESSAGE_MAP(CClientThread, CWinThread)
END_MESSAGE_MAP()

BOOL CClientThread::InitInstance()
{
	// 处理客户端连接的代码
	CSocket clientSocket;
	m_pMainWnd->SendMessage(WM_SOCKET_CONNECTED, (WPARAM)&clientSocket.GetSafeSocketHandle());

	return TRUE;
}

int CClientThread::ExitInstance()
{
	return CWinThread::ExitInstance();
}

// 在服务器对话框类中添加以下成员变量和消息处理函数
class CMyServerDlg : public CDialogEx
{
public:
	afx_msg LRESULT OnSocketConnected(WPARAM wParam, LPARAM lParam);

protected:
	virtual void DoDataExchange(CDataExchange* pDX);
	virtual BOOL OnInitDialog();

private:
	CSocket m_serverSocket;
	CList<CSocket, CSocket&> m_clientSocketList;
	CList<CClientThread*, CClientThread*> m_clientThreadList;
};

void CMyServerDlg::DoDataExchange(CDataExchange* pDX)
{
	CDialogEx::DoDataExchange(pDX);
}

BOOL CMyServerDlg::OnInitDialog()
{
	CDialogEx::OnInitDialog();

	// 创建服务器Socket
	m_serverSocket.Create(1234);
	m_serverSocket.Listen();

	return TRUE;
}

LRESULT CMyServerDlg::OnSocketConnected(WPARAM wParam, LPARAM lParam)
{
	// 处理客户端连接
	CSocket* pClientSocket = (CSocket*)wParam;

	// 将客户端Socket加入到列表中
	m_clientSocketList.AddTail(*pClientSocket);

	// 创建并启动一个新的线程来处理客户端连接
	CClientThread* pThread = (CClientThread*)AfxBeginThread(RUNTIME_CLASS(CClientThread), THREAD_PRIORITY_NORMAL, 0, CREATE_SUSPENDED);
	pThread->m_pMainWnd = this;
	pThread->ResumeThread();

	// 将线程加入到列表中
	m_clientThreadList.AddTail(pThread);

	return 0;
}

客户端代码（CMyClientDlg.cpp）：

// 头文件中添加以下内容
#include <afxsock.h>

// 在客户端对话框类中添加以下成员变量和消息处理函数
class CMyClientDlg : public CDialogEx
{
public:
	afx_msg LRESULT OnSocketConnected(WPARAM wParam, LPARAM lParam);

protected:
	virtual void DoDataExchange(CDataExchange* pDX);
	virtual BOOL OnInitDialog();

private:
	CSocket m_clientSocket;
};

void CMyClientDlg::DoDataExchange(CDataExchange* pDX)
{
	CDialogEx::DoDataExchange(pDX);
}

BOOL CMyClientDlg::OnInitDialog()
{
	CDialogEx::OnInitDialog();

	// 创建客户端Socket
	m_clientSocket.Create();

	// 连接服务器
	m_clientSocket.Connect("127.0.0.1", 1234);

	return TRUE;
}

LRESULT CMyClientDlg::OnSocketConnected(WPARAM wParam, LPARAM lParam)
{
	// 处理连接成功事件
	CSocket* pServerSocket = (CSocket*)wParam;

	// 在这里进行数据交互等操作

	return 0;
}

注意：以上代码只是一个简单的示例，实际使用中可能需要根据需求进行适当的修改和完善。同时，需要在MFC应用程序的资源文件中添加相应的对话框资源。另外，使用多线程和Socket编程需要注意线程同步和资源释放的问题。