|
@@ -8,12 +8,7 @@
|
|
|
|
|
|
package org.smartboot.http;
|
|
|
|
|
|
-import org.smartboot.Message;
|
|
|
-import tech.smartboot.feat.core.Feat;
|
|
|
-import tech.smartboot.feat.core.common.enums.HeaderValueEnum;
|
|
|
-import tech.smartboot.feat.core.server.HttpHandler;
|
|
|
-import tech.smartboot.feat.core.server.HttpRequest;
|
|
|
-import tech.smartboot.feat.core.server.HttpResponse;
|
|
|
+import tech.smartboot.feat.restful.RestFeat;
|
|
|
|
|
|
public class Bootstrap {
|
|
|
static byte[] body = "Hello, World!".getBytes();
|
|
@@ -21,21 +16,27 @@ public class Bootstrap {
|
|
|
public static void main(String[] args) {
|
|
|
int cpuNum = Runtime.getRuntime().availableProcessors();
|
|
|
// 定义服务器接受的消息类型以及各类消息对应的处理器
|
|
|
- Feat.createHttpServer(options -> {
|
|
|
+// Feat.createHttpServer(options -> {
|
|
|
+// options.threadNum(cpuNum + 1)
|
|
|
+// .headerLimiter(0)
|
|
|
+// .readBufferSize(1024 * 4)
|
|
|
+// .writeBufferSize(1024 * 4);
|
|
|
+// }).httpHandler(request -> {
|
|
|
+// HttpResponse response = request.getResponse();
|
|
|
+// if ("/plaintext".equals(request.getRequestURI())) {
|
|
|
+// response.setContentLength(body.length);
|
|
|
+// response.setContentType(HeaderValueEnum.ContentType.TEXT_PLAIN_UTF8);
|
|
|
+// response.write(body);
|
|
|
+// } else if ("/json".equals(request.getRequestURI())) {
|
|
|
+// response.setContentType("application/json");
|
|
|
+// JsonUtil.writeJsonBytes(response, new Message("Hello, World!"));
|
|
|
+// }
|
|
|
+// }).listen(8080);
|
|
|
+ RestFeat.createServer(options -> {
|
|
|
options.threadNum(cpuNum + 1)
|
|
|
.headerLimiter(0)
|
|
|
.readBufferSize(1024 * 4)
|
|
|
.writeBufferSize(1024 * 4);
|
|
|
- }).httpHandler(request -> {
|
|
|
- HttpResponse response = request.getResponse();
|
|
|
- if ("/plaintext".equals(request.getRequestURI())) {
|
|
|
- response.setContentLength(body.length);
|
|
|
- response.setContentType(HeaderValueEnum.ContentType.TEXT_PLAIN_UTF8);
|
|
|
- response.write(body);
|
|
|
- } else if ("/json".equals(request.getRequestURI())) {
|
|
|
- response.setContentType("application/json");
|
|
|
- JsonUtil.writeJsonBytes(response, new Message("Hello, World!"));
|
|
|
- }
|
|
|
}).listen(8080);
|
|
|
}
|
|
|
|