Yeah. I get the solution.
I learn sth from the IoFuture.
add an object to the session as lock and then wait after send message.
After i receive the message, i notify it.
Using this way, i turn the way from polling to inturrpted.
On 11/14/06, sishen <[EMAIL PROTECTED]> wrote:
hi, everyone.
I profiled my application, and found that this way indeed got bad
perfermance..
Can you give me some advice, thanks.
On 11/3/06, sishen <[EMAIL PROTECTED]> wrote:
>
>
>
> On 11/3/06, Hieu Phan Thanh < [EMAIL PROTECTED]> wrote:
> >
> > Hello,
> >
> > You could not check by the code:
> > while(!IoSession.containsAttribute("result"));
> > Because the IoSession instances are different between Server side and
> > Client side (2 different processes).
>
>
> No. you misunderstand my meaning.
> I use this way because there are the same IoSession.
>
> More details. I hope now i explain my idea more clearly, :)
>
> Client:
>
> public class ResultMessageHandler implements MessageHandler {
>
> public void messageReceived(IoSession session, Object message)
> throws Exception {
> // TODO Auto-generated method stub
> ResultMessage result = (ResultMessage)message;
> session.setAttribute("result", result);
> }
> }
>
> ResultMessage is decoded by the class ResultMessageDecoder, which is
> implemented in another class of mine.
>
> public class ClientSessionHandler extends DemuxingIoHandler {
> public ClientSessionHandler() {
> super.addMessageHandler(ResultMessage.class , new
> ResultMessageHandler());
> super.addMessageHandler(ErrorMessage.class, new
> ErrorMessageHandler());
> }
> }
>
> public class Client {
> IoSession session;
> ConnectFuture future = connector.connect(new
> InetSocketAddress(host, port), handler, cfg);
> future.join();
> session = future.getSession();
>
> while (!session.containsAttribute("result")
> ;
> }
>
> I can ensure that i can read the attribute from the same IoSession.
>
> But i don't prefer the way i use in the class "ResultMessageHandler". I
> want a more flexible way than setAttribute().
> Because using containsAttribute to judge whether i have received
> ResultMessage may block the whole application
> unexpectedly, i'm afraid.
>
>
>
> You should modify the protocol: server will send the acknowledge (ACK)
> > back to client whenever the message is received completely via the
> > messageReceived() of MINA framework. How do you think?
> >
> > I have been working around this protocol for month in my current
> > project.
> >
> > Thanks & best regards,
> > Hieu Phan.
> >
> > > -----Original Message-----
> > > From: sishen [mailto: [EMAIL PROTECTED]
> > > Sent: Thursday, November 02, 2006 3:05 PM
> > > To: [email protected]
> > > Subject: Re: How to get the received message object?
> > >
> > > On 11/1/06, Hieu Phan Thanh < [EMAIL PROTECTED]> wrote:
> > > >
> > > > Hi,
> > > >
> > > > > But i don't know when the result message is done. I use
> > > > I don't know what you meant when saying "when the result message
> > is
> > > > done"? MINA just helps us to transfer the message. And you have to
> > > > customize and handle the processing logic of the system yourself.
> > > > Please give me more detail or something related. Hope I could help
> >
> > you
> > > > guy.
> > >
> > >
> > > That's when the message is received by client totally.
> > > for (::) {
> > > try {
> > > ConnectFuture future = connector.connect(new
> > InetSocketAddress(host,
> > > port), handler, cfg);
> > > future.join();
> > > session = future.getSession();
> > > break;
> > > } catch ... {
> > > }
> > > }
> > >
> > > When i connect to the server, i send a query message. And
> > furture.join()
> > > is
> > > return just when the connection is established.
> > >
> > > I want to ensure that i have received the request message which is
> > sent by
> > > the server. My question is how can i do this?
> > >
> > > Now i use
> > >
> > > when received message,
> > > I set an attribute in the IoSession. IoSession.setAttribute
> > ("result",
> > > object);
> > >
> > > and in the client's process flow, i use while statement to ensure
> > the
> > > message is received totally.
> > >
> > > while ( !IoSession.containsAttribute("result") )
> > > ;
> > >
> > > I'm seeking a better way. Thx for advice, :)
> > >
> > > > Thanks & best regards,
> > > > Hieu Phan.
> > > >
> > > > > -----Original Message-----
> > > > > From: sishen [mailto: [EMAIL PROTECTED]
> > > > > Sent: Wednesday, November 01, 2006 4:26 PM
> > > > > To: [email protected]
> > > > > Subject: How to get the received message object?
> > > > >
> > > > > public class ResultMessageHandler implements MessageHandler {
> > > > > public void messageReceived(IoSession session, Object
> > message)
> > > > throws
> > > > > Exception {
> > > > > ResultMessage result = (ResultMessage)message;
> > > > > System.out.println("Message Received: ResultMessage");
> > > > > }
> > > > > }
> > > > >
> > > > > when i received the ResultMessage, i need to save it.
> > > > >
> > > > > Now i use
> > > > > session.setAttribute("result", result);
> > > > > And in the client,
> > > > > ResultMessage result =
> > (ResultMessage)session.getAttribute("result");
> > > > >
> > > > > But i don't know when the result message is done. I use
> > > > > while (!session.containsAttribute("result"))
> > > > > ;
> > > > > ResultMessage result =
> > (ResultMessage)session.getAttribute("result");
> > > > >
> > > > > But this has an problem, which is that when the server met an
> > mistake,
> > > > it
> > > > > will block forever. I do not prefer this way.
> > > > >
> > > > >
> > > > > I want to know whether there is a way to solve this problem. I
> > want
> > > > to
> > > > > return the message the server sent to me.
> > > > >
> > > > > thx~
> > > >
> > > >
> >
> >
>
