dinstone/photon

photon is a message exchange framework

Photon

Overview

Photon is an asynchronous message exchange framework based on Netty.

Features

• Efficient custom protocol (Photon message exchange protocol)

  • Request-Response Pattern
  • One-way / Notify Pattern

• High-performance NIO socket framework support - Netty4

Quick Start

add dependency:

<dependency>
	<groupId>com.dinstone.photon</groupId>
	<artifactId>photon</artifactId>
	<version>1.2.3</version>
</dependency>

message provider:

public static void main(String[] args) throws Exception {
  AcceptOptions acceptOptions = new AcceptOptions();
  acceptOptions.setEnableSsl(true);
  acceptOptions.setIdleTimeout(60000);
  SelfSignedCertificate cert = new SelfSignedCertificate();
  acceptOptions.setPrivateKey(cert.key());
  acceptOptions.setCertChain(new X509Certificate[] { cert.cert() });
  Acceptor acceptor = new Acceptor(acceptOptions);
  acceptor.setMessageProcessor(new MessageProcessor() {

    @Override
    public void process(Connection connection, Request req) {
      LOG.info("Request is {}", req.getSequence());
      Notice notice = new Notice();
      notice.setAddress("order.created");
      notice.setContent(req.getContent());
      CompletableFuture<Void> f = connection.sendMessage(notice);
      f.thenAccept((v) -> {
        Response response = new Response();
        response.setSequence(req.getSequence());
        response.setStatus(Status.SUCCESS);
        response.setContent(req.getContent());
        connection.sendMessage(response);
      });
    }

  });

  acceptor.bind(new InetSocketAddress("127.0.0.1", 4444));

  System.in.read();

  acceptor.destroy().awaitUninterruptibly();
}

message consumer:

public static void main(String[] args) throws Throwable {
  ConnectOptions connectOptions = new ConnectOptions();
  connectOptions.setEnableSsl(true);
  Connector connector = new Connector(connectOptions);

  Connection connection = connector.connect(new InetSocketAddress("127.0.0.1", 4444));
  LOG.info("channel active is {}", connection.isActive());

  Request request = new Request();
  request.setSequence(1);
  request.setTimeout(10000);
  request.setContent("Hello World".getBytes());

  LOG.info("async request is  {}", request);
  connection.sendRequest(request).thenAccept(response -> {
    LOG.info("async response is {}", response);
  });

  request = new Request();
  request.setSequence(2);
  request.setTimeout(3000);

  LOG.info("sync request is  {}", request);
  Response response = connection.sendRequest(request).get();
  LOG.info("sync response is {}", response);
  
  System.in.read();

  connector.destroy().awaitUninterruptibly();
}