diff --git a/pom.xml b/pom.xml index a2d83bd62d90494b38c6bc6ef5e17f08b6ebeadd..bdf72b2a8e59c117994b0872c8a6657f3b89f9d7 100644 --- a/pom.xml +++ b/pom.xml @@ -267,7 +267,7 @@ <dependency> <groupId>com.corundumstudio.socketio</groupId> <artifactId>netty-socketio</artifactId> - <version>1.0.1</version> + <version>1.7.1</version> </dependency> <dependency> <groupId>javax.inject</groupId> diff --git a/src/main/java/de/thm/arsnova/socket/ARSnovaSocketIOServer.java b/src/main/java/de/thm/arsnova/socket/ARSnovaSocketIOServer.java index 9348cf97c0146e180d14905ad71317bcf9e1f07d..3398c652a09a3d4a816995a188b0343216f07a6d 100644 --- a/src/main/java/de/thm/arsnova/socket/ARSnovaSocketIOServer.java +++ b/src/main/java/de/thm/arsnova/socket/ARSnovaSocketIOServer.java @@ -1,5 +1,7 @@ package de.thm.arsnova.socket; +import io.netty.channel.ChannelOption; + import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.InputStream; @@ -15,16 +17,18 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Required; +import org.springframework.stereotype.Component; import com.corundumstudio.socketio.AckRequest; import com.corundumstudio.socketio.Configuration; +import com.corundumstudio.socketio.SocketConfig; import com.corundumstudio.socketio.SocketIOClient; import com.corundumstudio.socketio.SocketIOServer; import com.corundumstudio.socketio.listener.ConnectListener; import com.corundumstudio.socketio.listener.DataListener; import com.corundumstudio.socketio.listener.DisconnectListener; -import com.corundumstudio.socketio.parser.Packet; -import com.corundumstudio.socketio.parser.PacketType; +import com.corundumstudio.socketio.protocol.Packet; +import com.corundumstudio.socketio.protocol.PacketType; import de.thm.arsnova.entities.User; import de.thm.arsnova.exceptions.NoContentException; @@ -34,6 +38,7 @@ import de.thm.arsnova.services.IUserService; import de.thm.arsnova.socket.message.Feedback; import de.thm.arsnova.socket.message.Session; +@Component public class ARSnovaSocketIOServer { @Autowired @@ -81,6 +86,9 @@ public class ARSnovaSocketIOServer { */ System.setProperty("java.net.preferIPv4Stack", "true"); + SocketConfig soConfig = new SocketConfig(); + soConfig.setReuseAddress(true); + config.setSocketConfig(soConfig); config.setPort(portNumber); config.setHostname(hostIp); if (useSSL) {