Class SocketServer

lang/java/ipc/src/main/java/org/apache/avro/ipc/SocketServer.java:43–151

A socket-based server implementation. This uses a simple, non-standard wire protocol and is not intended for production services. @deprecated use SaslSocketServer instead.

 * @deprecated use {@link SaslSocketServer} instead.
 */
@Deprecated
public class SocketServer extends Thread implements Server {
  private static final Logger LOG = LoggerFactory.getLogger(SocketServer.class);

  private Responder responder;
  private ServerSocketChannel channel;
  private ThreadGroup group;

  public SocketServer(Responder responder, SocketAddress addr) throws IOException {
    String name = "SocketServer on " + addr;

    this.responder = responder;
    this.group = new ThreadGroup(name);
    this.channel = ServerSocketChannel.open();

    channel.socket().bind(addr);

    setName(name);
    setDaemon(true);
  }

  @Override
  public int getPort() {
    return channel.socket().getLocalPort();
  }

  @Override
  public void run() {
    LOG.info("starting " + channel.socket().getInetAddress());
    try {
      while (true) {
        try {
          new Connection(channel.accept());
        } catch (ClosedChannelException e) {
          return;
        } catch (IOException e) {
          LOG.warn("unexpected error", e);
          throw new RuntimeException(e);
        }
      }
    } finally {
      LOG.info("stopping " + channel.socket().getInetAddress());
      try {
        channel.close();
      } catch (IOException e) {
      }
    }
  }

  @Override
  public void close() {
    this.interrupt();
    group.interrupt();
  }

  /**
   * Creates an appropriate {@link Transceiver} for this server. Returns a
   * {@link SocketTransceiver} by default.