winter 4 timmar sedan
förälder
incheckning
7ada0e9853
2 ändrade filer med 7 tillägg och 4 borttagningar
  1. +2
    -3
      bjairService/src/main/java/com/iformall/haikang/netty/NioSocketInitializer.java
  2. +5
    -1
      bjairService/src/main/java/com/iformall/haikang/netty/NioSocketServer.java

+ 2
- 3
bjairService/src/main/java/com/iformall/haikang/netty/NioSocketInitializer.java Visa fil

@@ -19,13 +19,12 @@ public class NioSocketInitializer extends ChannelInitializer<SocketChannel>{
private final Logger log = LoggerFactory.getLogger(this.getClass());

@Autowired
private ThreadPoolTaskExecutor threadPoolTaskExecutor;
@Autowired
private HKPeopleNumberFactory peopleNumberFactory;

public NioSocketInitializer(ThreadPoolTaskExecutor threadPoolTaskExecutor) {
public NioSocketInitializer(ThreadPoolTaskExecutor threadPoolTaskExecutor,HKPeopleNumberFactory peopleNumberFactory) {
this.threadPoolTaskExecutor = threadPoolTaskExecutor;
this.peopleNumberFactory = peopleNumberFactory;
}




+ 5
- 1
bjairService/src/main/java/com/iformall/haikang/netty/NioSocketServer.java Visa fil

@@ -6,6 +6,8 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Component;

import com.iformall.haikang.HKPeopleNumberFactory;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelOption;
@@ -19,6 +21,8 @@ public class NioSocketServer {
private final Logger log = LoggerFactory.getLogger(this.getClass());
@Autowired
private ThreadPoolTaskExecutor threadPoolTaskExecutor;
@Autowired
private HKPeopleNumberFactory peopleNumberFactory;

private EventLoopGroup bossGroup;
private EventLoopGroup workerGroup;
@@ -32,7 +36,7 @@ public class NioSocketServer {
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.childHandler(new NioSocketInitializer(threadPoolTaskExecutor))
.childHandler(new NioSocketInitializer(threadPoolTaskExecutor,peopleNumberFactory))
.option(ChannelOption.SO_BACKLOG, 128)
.childOption(ChannelOption.SO_KEEPALIVE, true);



Laddar…
Avbryt
Spara