?
#include?
"
stdafx.h
"
#include?
"
ace/OS_NS_time.h
"
#include?
"
ace/Log_Msg.h
"
#include?
"
ace/Reactor.h
"
#include?
"
ace/Event_Handler.h
"
#include?
"
ace/INET_Addr.h
"
#include?
"
ace/SOCK_Dgram.h
"
#include?
"
ace/TP_Reactor.h
"
#include?
"
ace/WFMO_Reactor.h
"
class
?ClientRecv?:?
public
?ACE_Event_Handler
{
public
:
????
virtual
?
~
ClientRecv?()
{}
????
int
?open?(
const
?ACE_INET_Addr?
&
bind_addr);
????
//
?Get?this?handler's?I/O?handle.
????
virtual
?ACE_HANDLE?get_handle?(
void
)?
const
????
{?
return
?
this
->
udp.get_handle();?}
????
virtual
?
int
?handle_input?(ACE_HANDLE?fd?
=
?ACE_INVALID_HANDLE);
????
//
?Called?when?this?handler?is?removed?from?the?ACE_Reactor.
????
virtual
?
int
?handle_close?(ACE_HANDLE?handle,
????????ACE_Reactor_Mask?close_mask);
????
????ACE_SOCK_Dgram?udp;
}
;
int
ClientRecv::open?(
const
?ACE_INET_Addr?
&
bind_addr)
{
????
if
?(
this
->
udp.open?(bind_addr,?
1
)?
==
?
-
1
)
????????ACE_ERROR_RETURN?((LM_ERROR,
????????ACE_TEXT?(
"
%p\n
"
),
????????ACE_TEXT?(
"
udp.open
"
)),
????????
-
1
);
????
????
return
?
this
->
reactor?()
->
register_handler
????????(
this
,?ACE_Event_Handler::READ_MASK?);
}
int
?
ClientRecv::handle_close?(ACE_HANDLE?handle,
??????????????????????????ACE_Reactor_Mask?close_mask)
{
????
if
?(close_mask?
==
?ACE_Event_Handler::WRITE_MASK)
????????
return
?
0
;
????close_mask?
=
?ACE_Event_Handler::ALL_EVENTS_MASK?
|
????????ACE_Event_Handler::DONT_CALL;
????
this
->
reactor?()
->
remove_handler?(
this
,?close_mask);
????
this
->
udp.close();
????delete?
this
;
????
return
?
0
;
}
int
?
ClientRecv::handle_input?(ACE_HANDLE?fd?)
{
????
char
??buffer[
8192
]?
=
?
{
0
}
;
????ACE_INET_Addr??peer_addr;
????
if
(
-
1
?
==
?
this
->
udp.recv(buffer,
8192
,peer_addr))
????????ACE_ERROR_RETURN?((LM_ERROR,
????????ACE_TEXT?(
"
%p\n
"
),
????????ACE_TEXT?(
"
udp.recv
"
)),
????????
-
1
);
????
????ACE_DEBUG((LM_INFO,
"
%s\n
"
,peer_addr.get_host_addr()));
????
return
?
0
;
}
DWORD?WINAPI?LoopThread(LPVOID?lparam)
{
????ACE_Reactor::instance?()
->
run_reactor_event_loop?();
????
return
??
0
;
}
int
?_tmain(
int
?argc,?_TCHAR
*
?argv[])
{
????ACE_INET_Addr?bind_addr(
10703
);
????ClientRecv??client;
????????client.reactor(ACE_Reactor::instance?());??
????
if
(
-
1
?
==
?client.open(bind_addr))
????
{
????????
return
?
-
1
;
????}
????
????CreateThread(NULL,NULL,LoopThread,
0
,
0
,
0
);
????ACE_INET_Addr?send_addr;
????
for
(
int
?i
=
1024
;i
<
3333
;i
++
)
????
{
????????ACE_DEBUG((LM_INFO,
"
%d?\n
"
,i));
????????send_addr.
set
(i,
"
192.168.3.147
"
);
????????Sleep(
5000
);
????????
if
(client.udp.send(
"
ttt
"
,
3
,send_addr)?
==
?
-
1
)
????????
{
????????????ACE_DEBUG((LM_INFO,
"
%p
"
));
????????????
break
;
????????}
????}
????system(
"
pause
"
);
????ACE_Reactor::instance?()
->
end_reactor_event_loop?();
????
return
?
0
;
}
報錯:?
udp.recv:?connection?reset?
p?:?handle?is?not?a?socket?
莫非反應器只能用于TCP? , 沒辦法，先用WSAAsyncSelect吧。