From 0c5a15be653fe2a030d3d533be43056c724ced61 Mon Sep 17 00:00:00 2001 From: Mihai Moldovanu Date: Tue, 2 Aug 2022 16:20:09 +0300 Subject: [PATCH] Refactor without codec ..... --- src/main/java/ro/mihai/GreetingsService.java | 19 ++++++++++ src/main/java/ro/mihai/Main.java | 37 ++------------------ 2 files changed, 22 insertions(+), 34 deletions(-) create mode 100644 src/main/java/ro/mihai/GreetingsService.java diff --git a/src/main/java/ro/mihai/GreetingsService.java b/src/main/java/ro/mihai/GreetingsService.java new file mode 100644 index 0000000..2b24c2f --- /dev/null +++ b/src/main/java/ro/mihai/GreetingsService.java @@ -0,0 +1,19 @@ +package ro.mihai; + +import com.twitter.finagle.Service; +import com.twitter.finagle.http.Request; +import com.twitter.finagle.http.Response; +import com.twitter.finagle.http.Status; +import com.twitter.io.Buf; +import com.twitter.io.Reader; +import com.twitter.util.Future; + +public class GreetingsService extends Service { + @Override + public Future apply(Request request) { + String greeting = "Hello " + request.getParam("name"); + Reader reader = Reader.fromBuf(new Buf.ByteArray(greeting.getBytes(), 0, greeting.length())); + return Future.value(Response.apply(request.version(), Status.Ok(), reader)); + } +} + diff --git a/src/main/java/ro/mihai/Main.java b/src/main/java/ro/mihai/Main.java index adf7ba3..ffaeb9b 100644 --- a/src/main/java/ro/mihai/Main.java +++ b/src/main/java/ro/mihai/Main.java @@ -1,39 +1,8 @@ package ro.mihai; - -import com.twitter.finagle.Codec; +import ro.mihai.GreetingsService; import com.twitter.finagle.Http; -import com.twitter.finagle.Service; -import com.twitter.finagle.builder.ServerBuilder; -import com.twitter.finagle.http.codec.HttpCodec; -import com.twitter.util.Future; - - -import io.netty.handler.codec.http2.Http2Connection; -import org.jboss.netty.handler.codec.http.*; -import org.jboss.netty.handler.codec.http.HttpRequest; -import org.jboss.netty.handler.codec.http.HttpResponse; - -import java.net.InetSocketAddress; - -import static com.twitter.finagle.Http.Http2; - public class Main { - public static void main(String[] args) { - System.out.println("Hello world!"); - - Service service = new Service() { - public Future apply(HttpRequest request) { - DefaultHttpResponse response = new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK); - return Future.value(response); - } - }; - - HttpCodec blah = new HttpCodec(); - ServerBuilder.safeBuild(service, ServerBuilder.get() - .codec(blah) - .name("HttpServer") - .bindTo(new InetSocketAddress("localhost", 10000))); - } - + GreetingsService sServ = new GreetingsService(); + Http.serve(":8080", sServ); }