Skip to content

Commit 80138b1

Browse files
committed
update
1 parent 7cf46bb commit 80138b1

File tree

4 files changed

+32
-19
lines changed

4 files changed

+32
-19
lines changed

release.sh

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,3 @@
1-
mvn clean deploy -DskipTests -Prelease-sign-artifacts -Pscala-2.12
1+
mvn clean deploy -DskipTests -Prelease-sign-artifacts -Pscala-2.11
22
#https://oss.sonatype.org/#stagingRepositories
33
#mvn versions:set -DnewVersion={version}

serviceframework-jetty-9-server/src/main/java/net/csdn/http/server/JettyServer.java

Lines changed: 19 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -15,28 +15,24 @@
1515
* Created by allwefantasy on 29/6/2017.
1616
*/
1717
public class JettyServer {
18-
public Server createServer(String host, int port,
19-
int minThreads, int maxThreads,
20-
String staticDir,
21-
String templateDir,
22-
boolean staticEnable,
23-
boolean classPathEnable, boolean sessionEanble, AbstractHandler abstractHandler) {
24-
QueuedThreadPool threadPool = new QueuedThreadPool();
25-
threadPool.setMinThreads(minThreads);
26-
threadPool.setMaxThreads(maxThreads);
27-
28-
Server server = new Server(threadPool);
2918

19+
public ServerConnector createConnector(Server server, String host, int port) {
3020
HttpConfiguration httpConfig = new HttpConfiguration();
3121

3222
ServerConnector connector = new ServerConnector(server,
3323
new HttpConnectionFactory(httpConfig));
3424

35-
3625
connector.setPort(port);
3726
connector.setHost(host);
27+
return connector;
28+
}
3829

39-
server.addConnector(connector);
30+
public Server connfigureServer(Server server, String staticDir,
31+
String templateDir,
32+
boolean staticEnable,
33+
boolean classPathEnable,
34+
boolean sessionEanble,
35+
AbstractHandler abstractHandler) {
4036

4137
HandlerList handlers = new HandlerList();
4238

@@ -72,4 +68,14 @@ public Server createServer(String host, int port,
7268
server.setHandler(handlers);
7369
return server;
7470
}
71+
72+
public Server createServer(int minThreads, int maxThreads) {
73+
QueuedThreadPool threadPool = new QueuedThreadPool();
74+
threadPool.setMinThreads(minThreads);
75+
threadPool.setMaxThreads(maxThreads);
76+
Server server = new Server(threadPool);
77+
return server;
78+
79+
80+
}
7581
}

serviceframework-web/src/main/java/net/csdn/bootstrap/loader/impl/ControllerLoader.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ public Class loaded(DataInputStream classFile) {
7070

7171
enhancer.enhanceThisClass2(controllers);
7272
for (String item : WowCollections.split2(settings.get("application.controller.default",
73-
"net.csdn.api.controller.SystemInfoController,net.csdn.api.controller.APIDescController,"
73+
"net.csdn.api.controller.SystemInfoController,net.csdn.api.controller.APIDescController"
7474
), ",")) {
7575
try {
7676
moduleList.add(bindAction(Class.forName(item)));

serviceframework-web/src/main/java/net/csdn/modules/http/HttpServer.java

Lines changed: 11 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
import net.csdn.modules.http.support.HttpHolder;
2323
import org.eclipse.jetty.server.Request;
2424
import org.eclipse.jetty.server.Server;
25+
import org.eclipse.jetty.server.ServerConnector;
2526
import org.eclipse.jetty.server.handler.AbstractHandler;
2627

2728
import javax.servlet.ServletException;
@@ -79,10 +80,16 @@ public HttpServer(Settings settings, RestController restController, API api) {
7980
disableMysql = settings.getAsBoolean(ServiceFramwork.mode + ".datasources.mysql.disable", false);
8081
JettyServer jettyServer = new JettyServer();
8182
httpPort = settings.getAsInt("http.port", generateHttpPort());
82-
server = jettyServer.createServer(settings.get("http.host", ""),
83-
httpPort,
84-
settings.getAsInt("http.threads.min", 100),
85-
settings.getAsInt("http.threads.max", 1000),
83+
84+
server = jettyServer.createServer(settings.getAsInt("http.threads.min", 100),
85+
settings.getAsInt("http.threads.max", 1000));
86+
ServerConnector connector = jettyServer.createConnector(server, settings.get("http.host", ""), httpPort);
87+
connector.setIdleTimeout(settings.getAsInt("http.server.idleTimeout", 30000));
88+
89+
server.addConnector(connector);
90+
91+
92+
jettyServer.connfigureServer(server,
8693
settings.get("serviceframework.static.loader.classpath.dir", "assets"),
8794
environment.templateDirFile().getPath(),
8895
settings.getAsBoolean("application.static.enable", false), settings.getAsBoolean("serviceframework.static.loader.classpath.enable", false),

0 commit comments

Comments
 (0)