netty-socketio使用namespace

简介: 一、简介   netty-socketio中的namespace可以用于区别在相同连接地址下的不同用户,当两个不同的用户打开同一个页面的时候,可以使用namespace用来标记不同用户。例如我们可以在用户中心页面动态的获取用户的消息数目。

一、简介

  netty-socketio中的namespace可以用于区别在相同连接地址下的不同用户,当两个不同的用户打开同一个页面的时候,可以使用namespace用来标记不同用户。例如我们可以在用户中心页面动态的获取用户的消息数目。这里就可以使用到namespace。因为每个用户的id都是不一样的,我们可以使用id来标识每个用户的namespace。

二、示例

  服务器端代码:

package com.test.socket;

import com.corundumstudio.socketio.Configuration;
import com.corundumstudio.socketio.SocketIONamespace;
import com.corundumstudio.socketio.SocketIOServer;

public class SocketServer2 {
    public static void main(String[] args) throws InterruptedException {

        Configuration config = new Configuration();
        config.setHostname("localhost");
        config.setPort(9092);

        final SocketIOServer server = new SocketIOServer(config); 
        server.start();
        String uid = "1111";
        String namespace = String.format("/%s_%s", "msg", uid);//构建命名空间
        SocketIONamespace chat1namespace = server.addNamespace(namespace); //设置命名空间

        for (int i = 0; i < 50; i++) { 
            Thread.sleep(2000); 
             chat1namespace.getBroadcastOperations().sendEvent("message", 1); //每次发送数字一
        }

        Thread.sleep(Integer.MAX_VALUE);

        server.stop();
    }

}

  客户端message.html代码:

 1 <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
 2 <html>
 3 <head>
 4 <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
 5 <title>Insert title here</title>
 6    <script src="./jquery-1.9.1.js" type="text/javascript"></script> 
 7   <script type="text/javascript" src="./socket.io/socket.io.js"></script>
 8 
 9     <style>
10         body { 
11             padding:20px;
12         }
13         #console {  
14             overflow: auto; 
15         }
16         .username-msg {color:orange;}
17         .connect-msg {color:green;}
18         .disconnect-msg {color:red;}
19         .send-msg {color:#888}
20     </style>
21 
22 </head>
23 
24 <body>
25     
26     <h1>Netty-socketio Demo Chat</h1>
27     
28     <br/>
29 
30     <div id="console" class="well">
31     </div>
32     消息总数:<div id="msgnum">0</di>    
33 </body>
34 
35   
36          
37 <script type="text/javascript">
38         var socket =  io.connect('http://localhost:9092/msg_1111');
39 
40         socket.on('connect', function() {
41             output('<span class="connect-msg">Client has connected to the server!</span>');
42         });
43 
44         socket.on('message', function(data) {//收到消息后,将消息总数加一
45             var num = $("#msgnum").html();
46             num = parseInt(num) + data;
47             $("#msgnum").html(num);
48         });
49         
50         socket.on('disconnect', function() {
51             output('<span class="disconnect-msg">The client has disconnected!</span>');
52         });
53         function sendDisconnect() {
54             socket.disconnect();
55         } 
56          
57         function output(message) {
58             var currentTime = "<span class='time'>" +  new Date() + "</span>";
59             var element = $("<div>" + currentTime + " " + message + "</div>");
60             $('#console').prepend(element);
61         }
62         
63     </script>
64 </html>

  启动服务器,访问该网页,消息总数会每次加1。

目录
相关文章
|
存储 缓存 NoSQL
跟着源码学IM(十一):一套基于Netty的分布式高可用IM详细设计与实现(有源码)
本文将要分享的是如何从零实现一套基于Netty框架的分布式高可用IM系统,它将支持长连接网关管理、单聊、群聊、聊天记录查询、离线消息存储、消息推送、心跳、分布式唯一ID、红包、消息同步等功能,并且还支持集群部署。
13594 1
|
10月前
|
消息中间件 Oracle Dubbo
Netty 源码共读(一)如何阅读JDK下sun包的源码
Netty 源码共读(一)如何阅读JDK下sun包的源码
189 1
|
NoSQL Java Redis
跟着源码学IM(十二):基于Netty打造一款高性能的IM即时通讯程序
关于Netty网络框架的内容,前面已经讲了两个章节,但总归来说难以真正掌握,毕竟只是对其中一个个组件进行讲解,很难让诸位将其串起来形成一条线,所以本章中则会结合实战案例,对Netty进行更深层次的学习与掌握,实战案例也并不难,一个非常朴素的IM聊天程序。 原本打算做个多人斗地主练习程序,但那需要织入过多的业务逻辑,因此一方面会带来不必要的理解难度,让案例更为复杂化,另一方面代码量也会偏多,所以最终依旧选择实现基本的IM聊天程序,既简单,又能加深对Netty的理解。
200 1
|
10月前
|
编解码 前端开发 网络协议
Netty Review - ObjectEncoder对象和ObjectDecoder对象解码器的使用与源码解读
Netty Review - ObjectEncoder对象和ObjectDecoder对象解码器的使用与源码解读
220 0
|
10月前
|
编解码 安全 前端开发
Netty Review - StringEncoder字符串编码器和StringDecoder 解码器的使用与源码解读
Netty Review - StringEncoder字符串编码器和StringDecoder 解码器的使用与源码解读
298 0
|
分布式计算 网络协议 前端开发
【Netty底层数据交互源码】
【Netty底层数据交互源码】
115 0
|
Java 容器
【深入研究NIO与Netty线程模型的源码】
【深入研究NIO与Netty线程模型的源码】
|
编解码 弹性计算 缓存
Netty源码和Reactor模型
Netty源码和Reactor模型
124 0
|
设计模式 监控 前端开发
第 10 章 Netty 核心源码剖析
第 10 章 Netty 核心源码剖析
149 0
|
编解码 分布式计算 Java
基于 netty 封装的超简单通俗易用 服务端客户端交互框架 《net-framework》原理,源码和使用说明,开箱即用,只需要开发业务逻辑,完全自定义无限扩充 [结尾附github源码]
基于 netty 封装的超简单通俗易用 服务端客户端交互框架 《net-framework》原理,源码和使用说明,开箱即用,只需要开发业务逻辑,完全自定义无限扩充 [结尾附github源码]
基于 netty 封装的超简单通俗易用 服务端客户端交互框架 《net-framework》原理,源码和使用说明,开箱即用,只需要开发业务逻辑,完全自定义无限扩充 [结尾附github源码]