SocketIoService.java

server.addEventListener("SET-GROUP-CHAT-KEY", Map.class, new DataListener<Map>() {
            @Override
            public void onData(final SocketIOClient client, Map data, AckRequest ackRequest) {
                String key = client.get("roomKey");
                //如果原有房間號(hào)不為空，且原有的房間號(hào)和當(dāng)前要設(shè)置的房間號(hào)不相等，則離開原有的房間
                if(key != null && !key.equals(data.get("roomKey").toString())) {
                    client.leaveRoom(key);
                    log.info("ID為" + client.getSessionId() + "離開了房間號(hào)為：" + key);
                }
                //如果原有的記間號(hào)為空，或者原有的房間號(hào)和當(dāng)前要設(shè)置房間不相等，則設(shè)置房間號(hào)
                if(key == null) {
                    client.joinRoom(data.get("roomKey").toString());//進(jìn)入房間
                    client.set("roomKey", data.get("roomKey").toString());
                    client.set("userId", data.get("userId").toString());
                    client.set("userName", data.get("userName").toString());
                    client.set("userFace", data.get("userFace").toString());
                    log.info(client.get("roomKey").toString());
                    log.info(client.get("userId").toString());
                    log.info(client.get("userName").toString());
                    log.info(client.get("userFace").toString());
                    log.info("ID為" + client.getSessionId() + "設(shè)置了房間號(hào)為：" + data.get("roomKey").toString());
                }
                StringBuffer sb = new StringBuffer();
                for (SocketIOClient c : server.getRoomOperations(client.get("roomKey").toString()).getClients()) {
//                    sb.append(c.get("userId")).append(" ").append(c.get("userName")).append(" ").append(c.get("userFace")).append("\n");
                    sb.append(c.getRemoteAddress()).append("\n");
                }
                sb.append("--------------------").append("\n");
                for (SocketIOClient c : server.getRoomOperations(client.get("roomKey").toString()).getClients()) {
                    c.sendEvent(client.get("roomKey").toString(), sb);
                }
            }
        });
        //接收群聊消息
        /*server.addEventListener("GROUP-CHAT-MESSAGE", Map.class, new DataListener<Map>() {
            @Override
            public void onData(final SocketIOClient client, Map data, AckRequest ackRequest) {
                for (SocketIOClient c : server.getRoomOperations(data.get("roomKey").toString()).getClients()) {
                    c.sendEvent(data.get("roomKey").toString(), data);
                }
                log.info("向" + data.get("roomKey").toString() + "廣播了:" + data);
            }
        });*/
        //下線監(jiān)聽(tīng)
        server.addDisconnectListener(new DisconnectListener(){
            @Override
            public void onDisconnect(SocketIOClient socketIOClient) {
                log.info(socketIOClient.get("userName").toString() + "離開了...............");
                StringBuffer sb = new StringBuffer();
                for (SocketIOClient c : server.getRoomOperations(socketIOClient.get("roomKey").toString()).getClients()) {
//                    sb.append(c.get("userId")).append(" ").append(c.get("userName")).append(" ").append(c.get("userFace")).append("\n");
                    sb.append(c.getRemoteAddress()).append("\n");
                }
                sb.append("--------------------").append("\n");
                for (SocketIOClient c : server.getRoomOperations(socketIOClient.get("roomKey").toString()).getClients()) {
                    c.sendEvent(socketIOClient.get("roomKey").toString(), sb);
                }
            }
        });

test.jsp

<%@ page language="java" contentType="text/html; charset=UTF-8"%>
<%@ include file="/base.jsp"%>
<script type="text/javascript" src="/static/common/socket.io/socket.io.js"></script>
<script>
    var socket = io.connect('<%=CommonConstants.SERVER_HOST_ADDRESS%>:<%=CommonConstants.SOCKET_PORT%>');
    socket.on('connect',function() {
        //推送消息
        socket.emit('SET-GROUP-CHAT-KEY', {'roomKey':'test_7_0','userId':'7',"userName":'張強(qiáng)',"userFace":'/static/inxweb/img/avatar-boy.gif'});

        //接收消息
        socket.on('test_7_0',function(data){
            console.info(data);
        });
    });
    /*function send(message) {
        //推送消息
        socket.emit('GROUP-CHAT-MESSAGE', {'roomKey':'test_7_0','message':message});
    }*/
</script>