TCP Client 示例

在上文中我们已经了解了客户端架构。现在我们将展示一个客户端实现的示例。

我们将使用 Sumup Client 作为一个参考实现。

我们将移除掉样板代码并专注于重要结构上。以下是为客户端代码：

  1. public static void main(String[] args) throws Throwable {
  2.     NioSocketConnector connector = new NioSocketConnector();
  3.     connector.setConnectTimeoutMillis(CONNECT_TIMEOUT);
  5.     if (USE_CUSTOM_CODEC) {
  6.     connector.getFilterChain().addLast("codec",
  7.         new ProtocolCodecFilter(new SumUpProtocolCodecFactory(false)));
  8.     } else {
  9.         connector.getFilterChain().addLast("codec",
  10.             new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
  11.     }
  13.     connector.getFilterChain().addLast("logger", new LoggingFilter());
  14.     connector.setHandler(new ClientSessionHandler(values));
  15.     IoSession session;
  17.     for (;;) {
  18.         try {
  19.             ConnectFuture future = connector.connect(new InetSocketAddress(HOSTNAME, PORT));
  20.             future.awaitUninterruptibly();
  21.             session = future.getSession();
  22.             break;
  23.         } catch (RuntimeIoException e) {
  24.             System.err.println("Failed to connect.");
  25.             e.printStackTrace();
  26.             Thread.sleep(5000);
  27.         }
  28.     }
  30.     // wait until the summation is done
  31.     session.getCloseFuture().awaitUninterruptibly();
  32.     connector.dispose();
  33. }

要构建一个客户端，我们需要做以下事情：

  • 创建一个 Connector
  • 创建一个 Filter Chain
  • 创建一个 IOHandler 并添加到 Connector
  • 绑定到服务器

下面解释每个细节

创建一个 Connector

  1. NioSocketConnector connector = new NioSocketConnector();

现在，我们已经创建了一个 NIO Socket 连接器

创建一个 Filter Chain

  1. if (USE_CUSTOM_CODEC) {
  2.     connector.getFilterChain().addLast("codec",
  3.         new ProtocolCodecFilter(new SumUpProtocolCodecFactory(false)));
  4. } else {
  5.     connector.getFilterChain().addLast("codec",
  6.         new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
  7. }

我们为 Connector 的 Filter Chain 添加了一些过滤器。这里我们添加的是一个 ProtocolCodec 到过滤器链。

创建 IOHandler

  1. connector.setHandler(new ClientSessionHandler(values));

这里我们创建了一个 ClientSessionHandler 的实例并将其设置为 Connector 的处理器。

绑定到服务器

  1. IoSession session;
  3. for (;;) {
  4.     try {
  5.         ConnectFuture future = connector.connect(new InetSocketAddress(HOSTNAME, PORT));
  6.         future.awaitUninterruptibly();
  7.         session = future.getSession();
  8.         break;
  9.     } catch (RuntimeIoException e) {
  10.         System.err.println("Failed to connect.");
  11.         e.printStackTrace();
  12.         Thread.sleep(5000);
  13.     }
  14. }

这是最重要的部分。我们将连接到远程服务器。因为是异步连接任务，我们使用了 ConnectFuture 来了解何时连接完成。一旦连接完成，我们将得到相关联的 IoSession。要向服务器端发送任何消息，我们都要写入 session。所有来自服务器端的响应或者消息都将穿越 Filter chain 并最终由 IoHandler 处理。

译者注：翻译版本的项目源码见 https://github.com/waylau/apache-mina-2-user-guide-demos 中的com.waylau.mina.demo.sumup包下