程序中使用了class CMySocket : public CSocket;使用了OnReceive事件。在只有TCP时的程序都能接收数据,但加上UDP之后这个消息就没反应了(UDP和TCP使用不同端口,UDP使用一个线程接收、一个线程发送。程序的目的是UDP接收的数据通过TCP发出去、TCP接收的数据通过UDP发出去,哪位大侠有代码参考就最好了)
解决方案 »
- 求助,制作PNG按钮,想从路径加载图片,不知道怎么实现?
- 在网吧机器上写一个桌面应用,当用户点击桌面logo后,打开指定的http地址,这个exe用什么写?
- CListCtrl排序的问题!?
- 请教一个简单的编译错误
- 请问用种子填充算法时种子点是怎样确定的?
- 哪位大哥能帮我调试一下呢,搞了两天了........
- 如果一直没有用户访问, ISAPI 能在 IIS 中贮留多久?
- 急!100分!
- extern CWave m_cWav m_cWav会重新在栈里分配内存吗?
- 用程序访问网络中的数据库,什么方法比较好?数据库用ACCESS建立。应该怎么作呢?
- 请教一个MFC中符号未定义的问题
- 不用数据库怎么实现输入一个公司的关键词能把有关公司的所有信息显示出来?
不过有个地方不明白,这个继承下来的CUDPSocket没看到在什么地方初始化成UDP的,我怎么知道它会按UDP协议收发数据呢?
Control ID
Type Member
IDC_EDITMSG
CEdit m_MSGIDC_LISTMSG
ClistBox
m_MSGS
---- 3. CAsyncSocket类用DoCallBack函数处理MFC消息,当一个网络事件发生时,DoCallBack函数按网络事件类型:FD_READ、FD_WRITE、FD_ACCEPT、FD_CONNECT分别调用OnReceive、OnSend、OnAccept、OnConnect函数。由于MFC把这些事件处理函数定义为虚函数,所以要生成一个新的C++类,以重载这些函数,做法如下: ---- 以Public方式继承CAsyncSocket类,生成新类MySock; ---- 为MySock类添加虚函数OnReceive、OnConnect、OnSend ---- 4. 在MySock.ccp中添加以下代码
#include "CSockClient.h"
#include "CSockClientDlg.h"
---- 5. 在MySock.h中添加以下代码
public: BOOL m_bConnected;
//是否连接 UINT m_nLength;
//消息长度 char m_szBuffer[4096];
//消息缓冲区
---- 6. 在MySock.ccp中重载各函数
MySock::MySock()
{
m_nLength=0;
memset(m_szBuffer,0,sizeof(m_szBuffer));
m_bConnected=FALSE;
}MySock::~MySock()
{
//关闭套接字
if(m_hSocket!=INVALID_SOCKET)
Close();
}
void MySock::OnReceive(int nErrorCode)
{
m_nLength=Receive(m_szBuffer,sizeof(m_szBuffer),0);
//下面两行代码用来获取对话框指针
CCSockClientApp* pApp=(CCSockClientApp*)AfxGetApp();
CCSockClientDlg* pDlg=(CCSockClientDlg*)pApp- >m_pMainWnd;
pDlg- >m_MSGS.InsertString(0,m_szBuffer);
memset(m_szBuffer,0,sizeof(m_szBuffer));
CAsyncSocket::OnReceive(nErrorCode);
}void MySock::OnSend(int nErrorCode)
{
Send(m_szBuffer,m_nLength,0);
m_nLength=0;
memset(m_szBuffer,0,sizeof(m_szBuffer));
//继续提请一个“读”的网络事件,接收Server消息
AsyncSelect(FD_READ);
CAsyncSocket::OnSend(nErrorCode);
}void MySock::OnConnect(int nErrorCode)
{
if (nErrorCode==0)
{
m_bConnected=TRUE;
CCSockClientApp* pApp=(CCSockClientApp*)AfxGetApp();
CCSockClientDlg* pDlg=(CCSockClientDlg*)pApp- >m_pMainWnd;
memcpy(m_szBuffer,"Connected to ",13);
strncat(m_szBuffer,pDlg- >m_szServerAdr,
sizeof(pDlg- >m_szServerAdr));
pDlg- >m_MSGS.InsertString(0,m_szBuffer);
AsyncSelect(FD_READ);
////提请一个“读”的网络事件,准备接收
} CAsyncSocket::OnConnect(nErrorCode);
}
---- 7. 新建对话框IDD_Addr,用来输入IP地址和Port;生成新类CAddrDlg。增加两个Edit控件:IDC_Addr、IDC_Port按下表在ClassWizard中为CAddrDlg类添加变量。
Control ID Type MemberIDC_Addr CString m_AddrIDC_Port Int m_Port
---- 8. 在CSockClientDlg.ccp中添加代码
#include "AddrDlg.h"
protected:
int TryCount;
MySock m_clientSocket;
UINT m_szPort;
public:
char m_szServerAdr[256]; ---- 9. 双击IDD_CSOCKCLIENT_DIALOG对话框中的“连接”按钮,添加以下代码
void CCSockClientDlg::OnConnect()
{
m_clientSocket.ShutDown(2);
m_clientSocket.m_hSocket=INVALID_SOCKET;
m_clientSocket.m_bConnected=FALSE;
CAddrDlg m_Dlg; //默认端口1088
m_Dlg.m_Port=1088;
if (m_Dlg.DoModal()==IDOK && !m_Dlg.m_Addr.IsEmpty())
{
memcpy(m_szServerAdr,m_Dlg.m_Addr,sizeof(m_szServerAdr));
m_szPort=m_Dlg.m_Port;
//建立计时器,每1秒尝试连接一次,直到连上或TryCount>10
SetTimer(1,1000,NULL);
TryCount=0;
}
}
---- 10. 添加Windows消息WM_TIMER响应函数OnTimer
void CCSockClientDlg::OnTimer(UINT nIDEvent)
{
if (m_clientSocket.m_hSocket==INVALID_SOCKET)
{
BOOL bFlag=m_clientSocket.Create(0,SOCK_STREAM,FD_CONNECT);
if(!bFlag)
{
AfxMessageBox("Socket Error!");
m_clientSocket.Close();
PostQuitMessage(0);
return;
}
} m_clientSocket.Connect(m_szServerAdr,m_szPort);
TryCount++;
if (TryCount >=10 || m_clientSocket.m_bConnected)
{
KillTimer(1);
if (TryCount >=10) AfxMessageBox("Connect Failed!");
return;
}
CDialog::OnTimer(nIDEvent);
}
---- 11. 双击IDD_CSOCKCLIENT_DIALOG对话框中的“发送”按钮,添加以下代码
void CCSockClientDlg::OnSend()
{
if (m_clientSocket.m_bConnected)
{
m_clientSocket.m_nLength= m_MSG.GetWindowText(m_clientSocket.m_szBuffer, sizeof(m_clientSocket.m_szBuffer));
m_clientSocket.AsyncSelect(FD_WRITE);
m_MSG.SetWindowText("");
}
}
---- 12. 双击IDD_CSOCKCLIENT_DIALOG对话框中的“关闭”按钮,添加以下代码
void CCSockClientDlg::OnExit()
{
//关闭Socket
m_clientSocket.ShutDown(2);
//关闭对话框
EndDialog(0);
}
----12.运行此项目,连接时输入主机名或IP均可,CAsyncSocket类会自动处理。 ----二. 服务端 ----Server端的编程与Client端的类似,下面主要介绍他的Listen及Accept函数 ----1. 建立一个CNewSocket类,重载CAsyncSocket类的OnReceive、OnSend函数, 如何进行信息的显示和发送可以参考Client程序。本例中采用将收到信息原封不动 发回的方法来实现Echo功能,代码如下
CNewSocket::OnReceive(int nErrorCOde)
{
m_nLength=Receive(m_szBuffer,sizeof(m_szBuffer),0);
// 直接转发消息AsyncSelect(FD_WRITE);
}CNewSocket::OnSend(int nErrorCode)
{
Send(m_szBuffer,m_nLength,0);
}
----2. 建立一个CMyServerSocket类,重载CAsyncSocket类的OnAccept函数代码如下 ----在MyServerSocket.h中声明变量
public::CNewSocket* m_pSocket;
void CMyServerSocket::OnAccept(int nErrorCode)
{
//侦听到连接请求,调用Accept函数
CNewSocket* pSocket = new CNewSocket();
if (Accept(*pSocket))
{
pSocket- >AsyncSelect(FD_READ);
m_pSocket=pSocket;
}
else
delete pSocket;
}
----3. 为对话框添加一个“侦听”按钮,添加如下代码 ----在CsockServerDlg.ccp中声明变量
public: CMyServerSocket m_srvrSocket;
void CCSockServerDlg::OnListen()
{
if(m_srvrSocket.m_hSocket==INVALID_SOCKET)
{
BOOL bFlag=m_srvrSocket.Create(UserPort,SOCK_STREAM,FD_ACCEPT);
if (!bFlag)
{
AfxMessageBox(“Socket Error!”);
M_srvrSocket.Close();
PostQuitMessage(0);
Return;
}
}
//“侦听”成功,等待连接请求
if (!m_srvrSocket。Listen(1))
{
int nErrorCode = m_srvrSocket.GetLastError();
if (nError!=WSAEWOULDBLOCK)
{
AfxMessageBox(“Socket Error!”);
M_srvrSocket.Close();
PostQuitMessage(0);
Return;
}
}
}
----4. 目前程序只能实现Echo功能,将信息原封不动的转发,若能将Accept中由 CNewSocket* pSocket = new CNewSocket(); 得到的Socket指针存入一个CList或一个数组中,便像Client端那样,对所有的连接进行读写控制。 ----三. 总结 ----CAsyncSocket类为我们使用Socket提供了极大方便。建立Socket的WSAStartup过程和bind过程被简化成为Create过程,IP地址类型转换、主机名和IP地址转换的过程中许多复杂的变量类型都被简化成字符串和整数操作,特别是CAsyncSocket