|
@@ -20,62 +20,57 @@ import java.util.Objects;
|
|
|
|
|
|
|
|
|
public class VoovanTFB {
|
|
|
- private static final String HELLO_WORLD_STR = "Hello, World!";
|
|
|
- private static final byte[] HELLO_WORLD_BYTES = "Hello, World!".getBytes();
|
|
|
+ private static final String HELLO_WORLD_STR = "Hello, World!";
|
|
|
+ private static final byte[] HELLO_WORLD_BYTES = "Hello, World!".getBytes();
|
|
|
|
|
|
- public static class Message {
|
|
|
+ public static class Message {
|
|
|
+ private final String message;
|
|
|
|
|
|
- private final String message;
|
|
|
+ public Message(String message) {
|
|
|
+ this.message = message;
|
|
|
+ }
|
|
|
|
|
|
- public Message(String message) {
|
|
|
- this.message = message;
|
|
|
- }
|
|
|
+ public String getMessage() {
|
|
|
+ return message;
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
- public String getMessage() {
|
|
|
- return message;
|
|
|
- }
|
|
|
+ private static final Message msg = new Message(HELLO_WORLD_STR);
|
|
|
|
|
|
- @Override
|
|
|
- public int hashCode() {
|
|
|
- return Objects.hash(message);
|
|
|
- }
|
|
|
- }
|
|
|
+ public static void main(String[] args) {
|
|
|
+ TReflect.register(Message.class);
|
|
|
|
|
|
- public static void main(String[] args) {
|
|
|
- TReflect.register(Message.class);
|
|
|
-
|
|
|
- WebServerConfig webServerConfig = WebContext.buildWebServerConfig();
|
|
|
- webServerConfig.setGzip(false);
|
|
|
- webServerConfig.setAccessLog(false);
|
|
|
- webServerConfig.setKeepAliveTimeout(1000);
|
|
|
- webServerConfig.setHost("0.0.0.0");
|
|
|
- webServerConfig.setPort(8080);
|
|
|
- webServerConfig.setHotSwapInterval(0);
|
|
|
- webServerConfig.setCache(true);
|
|
|
- webServerConfig.getModuleonfigs().clear();
|
|
|
- webServerConfig.getRouterConfigs().clear();
|
|
|
- webServerConfig.setEnablePathVariables(false);
|
|
|
+ WebServerConfig webServerConfig = WebContext.buildWebServerConfig();
|
|
|
+ webServerConfig.setGzip(false);
|
|
|
+ webServerConfig.setAccessLog(false);
|
|
|
+ webServerConfig.setKeepAliveTimeout(1000);
|
|
|
+ webServerConfig.setHost("0.0.0.0");
|
|
|
+ webServerConfig.setPort(8080);
|
|
|
+ webServerConfig.setHotSwapInterval(0);
|
|
|
+ webServerConfig.setCache(true);
|
|
|
+ webServerConfig.getModuleonfigs().clear();
|
|
|
+ webServerConfig.getRouterConfigs().clear();
|
|
|
+ webServerConfig.setEnablePathVariables(false);
|
|
|
webServerConfig.setEnableWebSocket(false);
|
|
|
-
|
|
|
- WebServer webServer = WebServer.newInstance(webServerConfig);
|
|
|
+ WebServer webServer = WebServer.newInstance(webServerConfig);
|
|
|
|
|
|
- //性能测试请求;
|
|
|
- webServer.get("/plaintext", new HttpRouter() {
|
|
|
- public void process(HttpRequest req, HttpResponse resp) throws Exception {
|
|
|
- resp.header().put(HttpStatic.CONTENT_TYPE_STRING, HttpStatic.TEXT_PLAIN_STRING);
|
|
|
- resp.write(HELLO_WORLD_BYTES);
|
|
|
- }
|
|
|
- });
|
|
|
- //性能测试请求
|
|
|
- webServer.get("/json", new HttpRouter() {
|
|
|
- public void process(HttpRequest req, HttpResponse resp) throws Exception {
|
|
|
- resp.header().put(HttpStatic.CONTENT_TYPE_STRING, HttpStatic.APPLICATION_JSON_STRING);
|
|
|
- resp.write(JSON.toJSON(new Message(HELLO_WORLD_STR), false, false));
|
|
|
- }
|
|
|
- });
|
|
|
+ //性能测试请求;
|
|
|
+ webServer.get("/plaintext", new HttpRouter() {
|
|
|
+ public void process(HttpRequest req, HttpResponse resp) throws Exception {
|
|
|
+ resp.header().put(HttpStatic.CONTENT_TYPE_STRING, HttpStatic.TEXT_PLAIN_STRING);
|
|
|
+ resp.write(HELLO_WORLD_BYTES);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ //性能测试请求
|
|
|
+ webServer.get("/json", new HttpRouter() {
|
|
|
+ public void process(HttpRequest req, HttpResponse resp) throws Exception {
|
|
|
+ resp.header().put(HttpStatic.CONTENT_TYPE_STRING, HttpStatic.APPLICATION_JSON_STRING);
|
|
|
+ resp.write(JSON.toJSON(msg, false, false));
|
|
|
+ }
|
|
|
+ });
|
|
|
|
|
|
- Logger.setEnable(false);
|
|
|
+ Logger.setEnable(false);
|
|
|
|
|
|
- webServer.serve();
|
|
|
- }
|
|
|
+ webServer.serve();
|
|
|
+ }
|
|
|
}
|