Thanks for reply.
That is right client is blocked...but i dont unterstand why client never get
data from server.
Server does not report any error.
This is the scenario.
1.Client connect to server
2. Server writes data to client (This is done in sessionOpen metnod,
initiali was in sessionCreated)
3. Client sends request to server.
4. Server response to client.
Some clinet stuck in step 2.
On Fri, Jul 25, 2008 at 3:55 PM, Oscar <[EMAIL PROTECTED]> wrote:
> Since your client uses the blocked socket, it is blocked at
> 'br.readLine()'.
>
> That is, client doesn't end until server feeds data to it.
>
>
> On Fri, Jul 25, 2008 at 7:25 PM, Zlatko Josic <[EMAIL PROTECTED]>
> wrote:
>
> > does session that entered idle state can write and read mesasage later?
> >
> > On Fri, Jul 25, 2008 at 1:17 PM, Zlatko Josic <[EMAIL PROTECTED]
> > >wrote:
> >
> > > Hi,
> > >
> > > tnis is snippet code of client
> > >
> > > for (int i = 0; i < stepNumber; i++) {
> > > ClientRequest request = new ClientRequest();
> > > request.setParameter("command", "addEVEronet");
> > > request.setParameter("Amt", "10");
> > > request.setParameter("phoneNumber", "0642361393");
> > > request.setParameter("serN", "000001");
> > > // slanje zahteva.
> > >
> > > // kreiranje soketa.
> > > Socket socket = null;
> > > BufferedReader br = null;
> > > PrintWriter pw = null;
> > > Map<String, Object> result = null;
> > > try {
> > > socket = new Socket(host, port);
> > > br = new BufferedReader(new
> > > InputStreamReader(socket.getInputStream()));
> > > pw = new PrintWriter(socket.getOutputStream());
> > > //citanje trenutnog vremena.
> > > result = readTransformator.transform(br.readLine());
> > > log.info(CollectionsUtil.formatMap(result));
> > >
> > > String currTime = (String)result.get("currT");
> > > //kriptovana vrednost.
> > > String crypt = Coder.decode(currTime);
> > > request.setParameter("orN", crypt);
> > > pw.println(writeTransformator
> > > .transform(request.getParameters()));
> > > pw.flush();
> > > result = readTransformator.transform(br.readLine());
> > > log.info(CollectionsUtil.formatMap(result));
> > > } catch (UnknownHostException e) {
> > > throw new DestinationNotAvailableException(e);
> > > } catch (IOException e) {
> > > throw new DestinationNotAvailableException(e);
> > > } finally {
> > > //zatvaranje resursa.
> > > SocketUtil.close(socket);
> > > IOUtil.close(br);
> > > IOUtil.close(pw);
> > >
> > > }
> > >
> > > sleepQuetly(3*1000);
> > > }// for
> > >
> > >
> > > and this is snippet of server code
> > >
> > > public void process(final MobileContext context) {
> > > //uzimanje sesije.
> > > IoSession session =
> (IoSession)context.getParameter("ioSession");
> > > TransactionDirector transactionDirector =
> > > (TransactionDirector)context.getParameter("transactionDirector");
> > > final DaoFactory daoFactory =
> > > (DaoFactory)context.getParameter("daoFactory");
> > > final Transaction transaction =
> > > transactionDirector.getTransaction();
> > > final Voucher voucher = transaction.getVoucher();
> > >
> > >
> > > final WriteFuture future =
> > >
> >
> session.write(transformator.transform(context.getResponse().getParameters()));
> > >
> > >
> > >
> > >
> > >
> > > future.addListener(new IoFutureListener<IoFuture>(){
> > >
> > > @Override
> > > public void operationComplete(IoFuture ioFuture) {
> > > try{
> > > WriteFuture newfuture = (WriteFuture)future.await();
> > > //WriteFuture future = (WriteFuture)ioFuture;
> > >
> > > //provera da li je podatak upisan.
> > > if (newfuture.isWritten()){
> > >
> > > //provera da li j u pitanju offline dopuna.
> > > if (voucher!= null){
> > > VoucherDao dao = daoFactory.getVoucherDao();
> > > //oznacavanje da je voucher iskoriscen.
> > > try {
> > > dao.updateUsed(voucher);
> > > } catch (DaoException e) {
> > > log.error("Nije oznaceno u bazi da je
> vaucer
> > > iskoriscen "+voucher.getId(),e);
> > > }
> > > }
> > > }else{
> > > //ako odgovor nije poslat terminalu vraca se vaucer
> u
> > > red.
> > > if (voucher != null){
> > > Queue queue =
> > (Queue)context.getParameter("queue");
> > > queue.putVoucher(voucher);
> > > }else{
> > > //TODO register for autostorno.
> > > }
> > > TransactionDao dao =
> daoFactory.getTransactionDao();
> > > try {
> > >
> > > dao.updateDelivered(transaction.getTransactionId(),NOT_DELIVERED);
> > > } catch (DaoException e) {
> > > log.error("Nije oznaceno u bazi da poruka nije
> > > isporucena klijentu "+transaction.getTransactionId());
> > > }
> > >
> > > //provera da li je doslo do greske pri slanju
> > odgovora.
> > > Throwable t = future.getException();
> > > if (t != null){
> > > log.error("Greska pri slanju odgovara klijentu
> za
> > > transakciju "+transaction.getTransactionId(),t);
> > > }
> > > }
> > >
> > >
> > > }catch(Throwable e){
> > > log.error("Ovde je problem",e);
> > > }
> > >
> > > }
> > >
> > > }
> > >
> > > );
> > > session.closeOnFlush();
> > >
> > >
> > >
> >
> //System.out.println(""+context.getResponse().getParameter(TerminalKeys.ERR));
> > > context.endProcessing();
> > >
> > >
> > > }
> > >
> > > On Fri, Jul 25, 2008 at 4:50 AM, Wenrui Guo <[EMAIL PROTECTED]
> > >wrote:
> > >
> > >> From my point of view, you had better post your code snippet from your
> > >> application. For example, the logic of client side.
> > >>
> > >> BR
> > >> anderson
> > >>
> > >> -----Original Message-----
> > >> From: Zlatko Josic [mailto:[EMAIL PROTECTED]
> > >> Sent: Friday, July 25, 2008 3:36 AM
> > >> To: [email protected]
> > >> Subject: problem
> > >>
> > >> Hi,
> > >>
> > >> I have server based on mina framework adn stupid socket client.
> > >> Messages sent to server have "\n\r" for end of message and messages
> > >> send to client have '\n' for end of message.
> > >>
> > >> When I start lot of clients some of clients never ends and server has
> > >> lotof sessionIdle method calls.
> > >>
> > >> what can be problem?
> > >>
> > >> Thanks for any help.
> > >>
> > >
> > >
> >
>
