Cettia Java Server A is a simple B and scalable C Java server designed to run on any platform on the Java Virtual Machine D.
- A
- Cettia 1.0.0-RC1 server.
- B
- All the interfaces you need to know are
Server
andServerSocket
. Indeed. - C
- Because servers don't share any data, you can scale application horizontally with ease.
- D
- Your application can run on any platform that Asity supports seamlessly i.e. Atmosphere, Grizzly, Java WebSocket API, Netty, Servlet and Vert.x.
Quick Start
Cettia Java Server is distributed through Maven Central and a single artifact, io.cettia:cettia-server:1.0.0-RC1
, is enough for general purpose. To run an application on the specific platform, you need to prepare the corresponding bridge artifact from Asity. Here to make the application run on an implementation of Servlet 3 and Java WebSocket API 1 io.cettia.asity:asity-bridge-servlet3:1.0.0-Beta1
and io.cettia.asity:asity-bridge-jwa1:1.0.0-Beta1
are used.
<dependency>
<groupId>io.cettia</groupId>
<artifactId>cettia-server</artifactId>
<version>1.0.0-RC1</version>
</dependency>
<dependency>
<groupId>io.cettia.asity</groupId>
<artifactId>asity-bridge-servlet3</artifactId>
<version>1.0.0-Beta1</version>
</dependency>
<dependency>
<groupId>io.cettia.asity</groupId>
<artifactId>asity-bridge-jwa1</artifactId>
<version>1.0.0-Beta1</version>
</dependency>
Once you’ve set up the build, you will be able to write the following echo and chat server.
import io.cettia.DefaultServer;
import io.cettia.Server;
import io.cettia.ServerSocket;
import io.cettia.asity.action.Action;
import io.cettia.asity.bridge.jwa1.AsityServerEndpoint;
import io.cettia.asity.bridge.servlet3.AsityServlet;
import io.cettia.transport.http.HttpTransportServer;
import io.cettia.transport.websocket.WebSocketTransportServer;
import javax.servlet.Servlet;
import javax.servlet.ServletContext;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.ServletRegistration;
import javax.servlet.annotation.WebListener;
import javax.websocket.DeploymentException;
import javax.websocket.server.ServerContainer;
import javax.websocket.server.ServerEndpointConfig;
@WebListener
public class Bootstrap implements ServletContextListener {
@Override
public void contextInitialized(ServletContextEvent event) {
// A cettia server
Server server = new DefaultServer();
// When a socket is created as the beginning of the lifecycle
server.onsocket((ServerSocket socket) -> {
System.out.println("on server's socket");
// Lifecycle events
// When the handshake is performed successfully
socket.onopen((Void v) -> System.out.println("on open"));
// When the underlying transport is closed for some reason
socket.onclose((Void v) -> System.out.println("on close"));
// When an error happens on the socket
socket.onerror((Throwable error) -> error.printStackTrace());
// When the socket has been closed for a long time i.e. 1 minute and deleted from the server as the end of the lifecycle
socket.ondelete((Void v) -> System.out.println("on delete"));
// echo and chat events
socket.on("echo", (Object data) -> {
System.out.println("on echo " + data);
socket.send("echo", data);
});
socket.on("chat", (Object data) -> {
System.out.println("on chat " + data);
server.all().send("chat", data);
});
});
HttpTransportServer httpTransportServer = new HttpTransportServer().ontransport(server);
final WebSocketTransportServer wsTransportServer = new WebSocketTransportServer().ontransport(server);
// Sets up the cettia server on Servlet and Java WebSocket API
// Of course, you can use other platform without touching the cettia server
ServletContext context = event.getServletContext();
Servlet servlet = new AsityServlet().onhttp(httpTransportServer);
ServletRegistration.Dynamic reg = context.addServlet(AsityServlet.class.getName(), servlet);
reg.setAsyncSupported(true);
reg.addMapping("/cettia");
ServerContainer container = (ServerContainer) context.getAttribute(ServerContainer.class.getName());
ServerEndpointConfig config = ServerEndpointConfig.Builder.create(AsityServerEndpoint.class, "/cettia")
.configurator(new ServerEndpointConfig.Configurator() {
@Override
public <T> T getEndpointInstance(Class<T> endpointClass) throws InstantiationException {
return endpointClass.cast(new AsityServerEndpoint().onwebsocket(wsTransportServer));
}
})
.build();
try {
container.addEndpoint(config);
} catch (DeploymentException e) {
throw new RuntimeException(e);
}
}
@Override
public void contextDestroyed(ServletContextEvent sce) {}
}
Example
Here are working examples.
Platform
Run a cettia application on any platform seamlessly.
Depdnency injection
Inject a server wherever you need.
Clustering
Scale a cettia application horizontally.