furynet

kryonet clone but using Netty and Apache Fury for serialization/deserialization

Example

Protocol

public static final List<Class<?>> PROTOCOL_EXAMPLE = List.of(
            ClientConnection.class,
            ClientDisconnection.class,
            Request.class,
            Response.class,
            BroadcastMessage.class
);

Client

 Client client = Client.builder()
            .hostname("127.0.0.1")
            .tcpPort(42000)
            .protocol(Protocol.PROTOCOL_EXAMPLE)
            .register(ClientConnection.class, (c, msg) -> logger.info("New player connected"))
            .register(ClientDisconnection.class, (c, msg) -> logger.info("A player disconnected"))
            .register(Response.class, (c, msg) -> logger.info("Received response msg {}", msg))
            .register(BroadcastMessage.class, (c, msg) -> logger.info("Received broadcasted msg {}", msg))
            .build();

client.start();

client.sendTcp(new Request("Hello there"));

Server

Server server = Server.builder()
        .tcpPort(42000)
        .protocol(Protocol.PROTOCOL_EXAMPLE)
        .register(ServerEvent.NEW_CLIENT_CONNECTION, (connection) -> {
            connection.sendToAllExceptTcp(new ClientConnection());
        })
        .register(ServerEvent.CLIENT_DISCONNECTED, (connection) -> {
            connection.sendToAllTcp(new ClientDisconnection());
        })
        .register(Request.class, (connection, msg) -> {
            connection.sentTcp(new Response());
        })
        .register(BroadcastMessage.class, (connection, msg) -> {
            connection.sendToAllExceptTcp(msg);
        })
        .build();

server.start();