Rooms

src/examples/java/MMOServer.java

@@ -1,11 +1,15 @@
 import mmo.core.netty.NettyBootstrap;
+import mmo.world.RoomManager;
 import network.NetworkFactory;
 
 import java.time.Duration;
+import java.util.Objects;
 
 public class MMOServer {
 
     public static void main(String[] args) {
+        Objects.requireNonNull(RoomManager.Companion.getInstance()).addRoom("test");
+
         NettyBootstrap bootstrap = new NettyBootstrap(new NetworkFactory(), 10000, Duration.ofSeconds(10));
         bootstrap.build();
     }

src/examples/java/network/NetworkSession.java

@@ -13,7 +13,6 @@ public NetworkSession(ChannelAdapter channel) {
 
     @Override
     public void close() {
-
     }
 
     @Override

src/main/java/mmo/core/netty/NettyBootstrap.kt

@@ -1,14 +1,12 @@
 package mmo.core.netty
 
 import io.netty.bootstrap.ServerBootstrap
-import io.netty.buffer.Unpooled
 import io.netty.channel.Channel
 import io.netty.channel.ChannelHandlerContext
 import io.netty.channel.ChannelInitializer
 import io.netty.channel.EventLoopGroup
 import io.netty.channel.nio.NioEventLoopGroup
 import io.netty.channel.socket.nio.NioServerSocketChannel
-import io.netty.handler.codec.DelimiterBasedFrameDecoder
 import io.netty.handler.timeout.IdleStateEvent
 import io.netty.handler.timeout.IdleStateHandler
 import mmo.core.Server
@@ -55,7 +53,7 @@ class NettyBootstrap<S : Session?>(private val factory: SessionFactory<S>, priva
         channel!!.closeFuture()
     }
 
-    override fun sessions(): Collection<S>? {
+    override fun sessions(): Collection<S> {
         return sessionHandlerAdapter!!.sessions()
     }
 }

src/main/java/mmo/world/Room.kt

@@ -0,0 +1,11 @@
+package mmo.world
+
+import io.netty.channel.ChannelId
+import mmo.core.session.Session
+import java.util.concurrent.ConcurrentHashMap
+
+class Room(@JvmField var name: String) {
+    var max: Int = -1
+
+    var users: ConcurrentHashMap<ChannelId, Session> = ConcurrentHashMap()
+}

src/main/java/mmo/world/RoomCode.kt

@@ -0,0 +1,9 @@
+package mmo.world
+
+enum class RoomCode {
+    Exists,
+    NotExists,
+    Full,
+    Fail,
+    Ok
+}

src/main/java/mmo/world/RoomManager.kt

@@ -0,0 +1,43 @@
+package mmo.world
+
+import org.apache.logging.log4j.LogManager
+import java.util.concurrent.ConcurrentHashMap
+
+class RoomManager {
+    private var rooms: ConcurrentHashMap<String, Room>? = null
+
+    private val logger = LogManager.getLogger(javaClass)
+
+    fun addRoom(name: String): RoomCode {
+        return if (rooms!!.containsKey(name)) RoomCode.Exists else try {
+            val room = Room(name)
+            rooms!![name] = room
+            logger.info("new room: {}", name)
+            RoomCode.Ok
+        } catch (ex: Exception) {
+            RoomCode.Fail
+        }
+    }
+
+    fun removeRoom(room: Room): RoomCode {
+        if (!rooms!!.containsKey(room.name)) return RoomCode.NotExists
+        return if (rooms!!.remove(room.name, room)) RoomCode.Ok else RoomCode.Fail
+    }
+
+    companion object {
+        var instance: RoomManager? = null
+            get() {
+                if (field == null) {
+                    field = build()
+                }
+                return field
+            }
+            private set
+
+        private fun build(): RoomManager {
+            val roomManager = RoomManager()
+            roomManager.rooms = ConcurrentHashMap()
+            return roomManager
+        }
+    }
+}