Apache Mina Client

Alican Akkuş bio photo By Alican Akkuş Comment

Merhaba arkadaslar, bir önceki yazımda Mina ile basit bir server socket’in nasıl oluşturulabileceğini, NIO tabanlı olduğunu ve mina hakkında birkaç detay vermiştik. Bugün ise Mina ile bir socket client oluşturmaya çalışacağız.

Apache Mina Client

Everything going to be ok if server socket is alive. > Alican Akkus

Bir önceki yazımızda server socketi olusturup herhangi bir port’a bind etmiş ve daha sonra telnet ile ip ve port adresini yazarak aslında bir client gibi davranmıştık. Bkz: telnet , bugün ise client kodunu yazacagız, mesaj göndereceğiz ve açtığımız session’un durumunu handle edeceğiz.

Mina ile client socket oluşturmak için şu adımları yapmalıyız;

  • Öncelik olarak server socketin alive olduğun u bilmemiz gerekiyor.
  • Socket Connector oluşturmak ve server ip üzerindeki porta bağlanmamız gerekiyor. Session almak.
  • Session kapandığında safe olacak biçimde yeni session almak, safe şekilde bağlantıyı kapatmak.
  • Mesaj göndermek için sessiona mesaj yazmak.

Bir önceki yazımda kullanmış olduğum IO handler sınıfını olduğu gibi kullanacağız. Yeni oluşturacağımız MinaClient sınıfını connector olarak çalıştıracağız;

MinaClient.java

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
package com.caysever.mina.tutorial.client;

import java.net.InetSocketAddress;
import java.nio.charset.Charset;

import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketConnector;

import com.caysever.mina.tutorial.TimeServerHandler;

public class MinaClient {

  private NioSocketConnector socketConnector = null;// socket connector
  private IoSession socketSession = null; // minanın bize atadıgı session
  private final String SERVER_ADRESS = "127.0.0.1"; // server ip
  private final int SERVER_PORT = 5003; // server port

  public boolean isServerConnectionAlive() {
    return socketSession != null && socketSession.isConnected(); // session null degil ve hala baglı?
  }

  public void createSocketConnector() {
    try {
                        //connector olustur ve filterları ekle
      socketConnector = new NioSocketConnector();
      socketConnector.getFilterChain().addLast("logger", new LoggingFilter());
      socketConnector.getFilterChain().addLast("protocol", new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));
                        //socket handler set
      socketConnector.setHandler(new TimeServerHandler());
      socketConnector.getSessionConfig().setReadBufferSize(2048);
      socketConnector.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 60);

    } catch (Exception e) {
      e.printStackTrace();
    }
  }

  public void closeServerConnection() {
                 //senkron kapat
    if (socketSession != null) {
      socketSession.close(false);
    }
    if (socketConnector != null) {
      socketConnector.dispose();
    }
  }

  public void openServerConnection() {

    try {
                      // session baglı degilse once bir connect olalım sonrasında session alalım.
      if (socketSession == null || socketSession != null && !socketSession.isConnected()) {
        ConnectFuture future = socketConnector.connect(new InetSocketAddress(SERVER_ADRESS, SERVER_PORT));
        future.awaitUninterruptibly();
        socketSession = future.getSession();
      } else {
        System.out.println("Session already active.");
      }
    } catch (Exception e) {
      e.printStackTrace();
    }
  }

  public void sendMessage(String message) {
                // server alive degilse once acmayi deneyeliö
    if (!isServerConnectionAlive()) {
      openServerConnection();
    }
                // server alive , o zaman sessiona yazalim mesajimizi.
    if (isServerConnectionAlive()) {
      System.out.println("session is open, sending message : " + message);
      socketSession.write(message);
    }
  }
}

Kod içerisinde gerekli yerlere yorumlar yazdım, yapı basit çünkü default protocol ile ilerliyoruz.  IoHandler, bir önceki yazımızdaki handler idi. Tekrar yer verelim;

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
package com.caysever.mina.tutorial;

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;

public class TimeServerHandler extends IoHandlerAdapter {

  @Override
  public void exceptionCaught(IoSession session, Throwable cause) throws Exception {
    System.out.println(cause.getMessage());
  }

  @Override
  public void messageSent(IoSession ioSession, Object obj) throws Exception {
    System.out.println("\nSent message :" + obj.toString());
  }

  @Override
  public void messageReceived(IoSession session, Object obj) throws Exception {
    String message = obj.toString();
    System.out.println("\nNew Message Received:" + message);
  }

  @Override
  public void sessionIdle(IoSession session, IdleStatus status) throws Exception {
    System.out.println("\nIDLE " + session.getIdleCount(status));
  }

  @Override
  public void sessionClosed(IoSession session) throws Exception {
    super.sessionClosed(session);
    System.out.println("\nSession closed.  Session ID:" + session.getId() + " - Local address:" + session.getLocalAddress() + " - Remote Address:"
        + session.getRemoteAddress() + " - Service Address:" + session.getServiceAddress() + " - TransportMetadata:" + session.getTransportMetadata());

    // connector.setSessionState(SessionState.closed);
  }

  @Override
  public void sessionCreated(IoSession session) throws Exception {
    super.sessionCreated(session);
    System.out.println("\nSession created .. ");
  }

  @Override
  public void sessionOpened(IoSession session) throws Exception {
    super.sessionOpened(session);
    System.out.println("\nSession opened. Session ID:" + session.getId() + " - Local address:" + session.getLocalAddress() + " - Remote Address:"
        + session.getRemoteAddress() + " - Service Address:" + session.getServiceAddress() + " - TransportMetadata:" + session.getTransportMetadata());

    // connector.setSessionState(SessionState.open);
  }

}

Test classımıza bakalım;

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
package com.caysever.mina.tutorial.client;

import java.util.Date;

public class ClientTest {

  public static void main(String[] args) {

    try {

      MinaClient client = new MinaClient();
      client.createSocketConnector();
      client.openServerConnection();

      while (true) {
        Date date = new Date();
        client.sendMessage("Client message [ " + date.getTime() + " ]");

        Thread.sleep(1000);
      }

    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}

Client’ımız servera bağlandıktan sonra 1 sn aralıklarla mesaj göndermekte. Örneği çalıştırabilmek için server socketin ayakta olması gerekmektedir. Bu nedenle bir önceki yazımda vermis oldugum uygulamayı çalıştırmış olmanız ve 5003 portunda gelen istekleri kabul ettiğini biliyor olmanız gerekmektedir. Yada yazının sonundaki projenin son halini indirip önce server kısmını çalıştırıp daha sonra client tarafını çalıştırırsanız yine çalışacaktır.

Eclipse üzerinde server ve client tarafını çalıştıralim ve consola bakalım. Kişisel tavsiyemdir; consola, log’a, exception tipine, satırına vs vs gibi verilere dikkat edin. Karşılaştığınız hatanın çözümü orada yer almaktadır, sadece doğru analiz etmek size kalan taraftır.

Öncelikle Server socketi ayağa kaldıralim;

server-created

Server socketin ayağa kalktıgını ve bir clientin baglandıgını görmekteyiz. Client, bizim olusturdugumuz client’dır. Client consola bakalım;

session-created

Client’ın session aldıktan sonra sessionu açmasını ve mesajı göndermesini görebilirsiniz. “Client message [1449351169754]” asıl gönderilen mesajdır.

Server’ın clienttan aldıgı mesajları görmek icin tekrar server consola dönelim;

session-message

Client uygulamasını durduralım ve serverın cevabına bakalım;

session-closed

Client tarafında; Connector oluşturmak ve ilgili ip/port’a bağlandıktan sonra session’a mesaj göndermek gibi işler duruyor. Ancak server socket tarafı daha karmaşıktır ve olması gerekende budur. Server socket’ın, bağlanan sessionları tutması, belirli bir sessiondan gelen mesajın karıştırılmaması ve cevap dönülecekse sadece ilgili sessiona cevap dönülmesi gerekmektedir. Bu ve buna benzer örnekler dolayısıla server socketin daha karmasık olması en azından client’a göre doğaldır.

Örnek basit bir client oluşturup mesaj gönderdik, bir sonraki yazımızda default protocol yerine kendi belirleyeceğimiz protocol üzerinden socketlerin haberleşmesini sağlayacağız.

Yazımı burada sonlandırmak istiyorum arkadaslar.

Uygulamanın son haline buradan erişebilirsiniz.

Alican Akkus.

comments powered by Disqus