微服务框架Finagle介绍 Part2: 在Finagle中开发基于Http协议的应用

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

public class Server extends Service<Request, Response> {                             //1

@Override
public Future<Response> apply(Request request) {                                 //2
System.out.println("request: " + request.getContentString());
Response response = Response.apply(Version.Http11$.MODULE$, Status.Ok());
response.setContentString(request.getContentString());
return Future.value(response);
}

public static void main(String[] args) throws Exception {
Server service = new Server();

ListeningServer server = Http.server().                                      //3
withLabel("echo-server").
withTracer(ZipkinTracer.mk("192.168.99.100",
9410, DefaultStatsReceiver$.MODULE$, 1.0f)).
serve(new InetSocketAddress(8081), service);

Await.result(server);
}
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
2223
24
25
26
27
28
29
30
3132
33
34
35

import static scala.compat.java8.JFunction.*;

public class Client {

public static void main(String[] args) throws TimeoutException, InterruptedException {
Service<Request, Response> service = Http.client().                             //1
withLabel("echo-client").
withTracer(ZipkinTracer.mk("192.168.99.100",
9410, DefaultStatsReceiver$.MODULE$, 1.0f)).
newService("127.0.0.1:8081");

//create a "Greetings!" request.
Reader data = Reader$.MODULE$.fromStream(                                       //2
new ByteArrayInputStream("Greetings!".getBytes(StandardCharsets.UTF_8)));
Request request = Request.apply(Version.Http11$.MODULE$,
Method.Post$.MODULE$, "/", data);

Future<Response> responseFuture = Await.ready(service.apply(request));          //3
responseFuture.onSuccess(func(response -> {                                     //4
System.out.println(String.format("response status: %s, response string: %s",
response.status().toString(), response.contentString()));
return BoxedUnit.UNIT;
}));
responseFuture.onFailure(func(e -> {
System.out.println("error: " + e.toString());
return BoxedUnit.UNIT;
}));
responseFuture.ensure(func(() -> {
service.close();
//IDE may complain here, just ignore
return BoxedUnit.UNIT;
}));

}
}

1
2
3
4
5
6
7
8

responseFuture.onSuccess(new AbstractFunction1<Response, BoxedUnit>(){
@Override
public BoxedUnit apply(Response response) {
System.out.println(String.format("response status: %s, response string: %s",
response.status().toString(), response.contentString()));
return BoxedUnit.UNIT;
}
});

1
2
3
4
5

responseFuture.onSuccess(response -> {
System.out.println(String.format("response status: %s, response string: %s",
response.status().toString(), response.contentString()));
return BoxedUnit.UNIT;
});

1

response status: Status(200), response string: Greetings!

1

request: Greetings!