From 09b583854ddeb50816a6cb22697f1867bd952c5c Mon Sep 17 00:00:00 2001 From: pankaj Date: Tue, 7 Oct 2014 13:52:24 -0700 Subject: [PATCH] Added simple netty server --- .../org/onlab/onos/foo/SimpleNettyServer.java | 38 +++++++++++++++++++ 1 file changed, 38 insertions(+) create mode 100644 apps/foo/src/main/java/org/onlab/onos/foo/SimpleNettyServer.java diff --git a/apps/foo/src/main/java/org/onlab/onos/foo/SimpleNettyServer.java b/apps/foo/src/main/java/org/onlab/onos/foo/SimpleNettyServer.java new file mode 100644 index 0000000000..1ec77394f8 --- /dev/null +++ b/apps/foo/src/main/java/org/onlab/onos/foo/SimpleNettyServer.java @@ -0,0 +1,38 @@ +package org.onlab.onos.foo; + +import java.io.IOException; + +import org.jboss.netty.handler.logging.LoggingHandler; +import org.onlab.netty.EchoHandler; +import org.onlab.netty.KryoSerializer; +import org.onlab.netty.NettyMessagingService; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * Test to measure Messaging performance. + */ + public class SimpleNettyServer { + private static Logger log = LoggerFactory.getLogger(IOLoopTestServer.class); + + private SimpleNettyServer() {} + + public static void main(String... args) throws Exception { + startStandalone(args); + System.exit(0); + } + + public static void startStandalone(String[] args) throws IOException { + NettyMessagingService server = new NettyMessagingService(8080); + try { + server.activate(); + } catch (Exception e) { + e.printStackTrace(); + } + server.setSerializer(new KryoSerializer()); + server.registerHandler("simple", + (org.onlab.netty.MessageHandler) new LoggingHandler()); + server.registerHandler("echo", new EchoHandler()); + } + } +