Netty-SocketIO:最好用的Java版即时消息推送(1)

简介: Netty-SocketIO:最好用的Java版即时消息推送

Netty-SocketIO是一个开源的、基于Netty的、Java版的即时消息推送项目。通过Netty-SocketIO,我们可以轻松的实现服务端主动向客户端推送消息的场景,比如说股票价格变化、K线图、消息提醒等。它和websocket有相同的作用,只不过Netty-SocketIO可支持所有的浏览器。


GitHub项目地址为: https://github.com/mrniko/netty-socketio


Socket.IO除了支持WebSocket通讯协议外,还支持许多种轮询(Polling)机制以及其它实时通信方式,并封装成了通用的接口,并且在服务端实现了这些实时机制的相应代码。Socket.IO实现的Polling通信机制包括Adobe Flash Socket、AJAX长轮询、AJAX multipart streaming、持久Iframe、JSONP轮询等。Socket.IO能够根据浏览器对通讯机制的支持情况自动地选择最佳的方式来实现网络实时应用。


###一、下载Netty-SocketIO


socket.io-client-master

netty-socketio-master

netty-socketio-demo-master

从netty-socketio的git上可下载到以上三个压缩包,分别对应的是web 客户端的所需文件、netty socketio的java服务端实现、以及对应的可以应用web推送的demo。


###二、部署server的资源项目

从git上下载的socketio server压缩包中没有项目所需的jar包,我是自己新建了一个项目,本来上传到了CSDN的代码库里了,但写博客的时候怎么也打不开了,那么只能提供对应项目导航图,同时提供jar包的下载地址,需要的可动手去获得。

image.png



http://mvnrepository.com/网站上课下载到需要的所有jar包。


然后将jar包添加到项目中。

切记jdk的版本一定要在1.7以上,我在本地环境中用的1.7,但是服务器上一直用的是1.6,部署项目的时候没有注意,导致服务端可以接收到客户端的socketio 的connect,但是客户端的response相应中却连接不通,开始的时候以为是跨域问题导致的,搜了好多帖子,但问题根本就是不是跨域引起的,jdk的版本换成1.7就ok了,因为netty的nio是基于java的1.7的。


###三、应用server

在需要应用socketio的项目上右键,为项目添加socketio项目支持(注意红色标出的)。

image.png


新建main类。

public static void main(String[] args) throws InterruptedException {
  Configuration config = new Configuration();
  config.setHostname("localhost");
  config.setPort(10015);
  SocketIOServer server = new SocketIOServer(config);
  server.addConnectListener(new ConnectListener() {// 添加客户端连接监听器
    @Override
    public void onConnect(SocketIOClient client) {
      logger.info(client.getRemoteAddress() + " web客户端接入");
      client.sendEvent("helloPush", "hello");
    }
  });
          // 握手请求
  server.addEventListener("helloevent", HelloUid.class, new DataListener<HelloUid>() {
    @Override
    public void onData(final SocketIOClient client, HelloUid data, AckRequest ackRequest) {
      // 握手
      if (data.getMessage().equals("hello")) {
        int userid = data.getUid();
        logger.info(Thread.currentThread().getName() + "web读取到的userid:" + userid);
        // send message back to client with ack callback
        // WITH data
        client.sendEvent("hellopush", new AckCallback<String>(String.class) {
          @Override
          public void onSuccess(String result) {
            logger.info("ack from client: " + client.getSessionId() + " data: " + result);
          }
        }, sessionTime);
      } else {
        logger.info("行情接收到了不应该有的web客户端请求1111...");
      }
    }
  });
        server.start();
        Thread.sleep(Integer.MAX_VALUE);
        server.stop();
    }


当client通过ip和端口连接到server后,会构造一个SocketIOClient client的对象,在实际的应用中,可以将该client保存起来,通过client.sendEvent("helloPush", "hello");就可以向client端发送相应的数据了。


###四、应用client

####①、引入socket.io.js


<script type="text/javascript" src="${ctx}/components/socketio/socket.io.js"></script>


####②、创建connection的公共方法

function connectQuotation(uid, callback) {
  // 链接行情server
  socket = io.connect('http://localhost:10015');
  // 如果用户在web端登陆,那么发送握手请求
  if (uid) {
    // 连接上server后
    socket.on('connect', function() {
      // 发送握手请求
      var jsonObject = {
        uid : parseInt(uid),
        message : "hello"
      };
      this.emit('helloevent', jsonObject);
      this.on('hellopush', function(data, ackServerCallback, arg1) {
        // base64转码的数据,可忽视
        YUNM.session = {
          sessionId : $.base64.atob(data.sessionId),
          time : $.base64.atob(data.time)
        };
        if (ackServerCallback) {
          ackServerCallback('server message was delivered to client!');
        }
      });
    });
  }
  // 如果web端session超时,socket断开,10分钟扫描一次
  int = window.setInterval(function() {
    // 我是通过ajax判断session超时的,你也可以通过其他方式
    $.ajax({
      type : 'POST',
      url : common.ctx + "/getSessionTimeout",
      dataType : "json",
      cache : false,
      success : function(json) {
        var timeout = parseInt(json.message);
        // session超时后,socket断开,服务端就可以监听到释放资源
        if (timeout == 0) {
          socket.disconnect();
        }
      },
      error : function() {
        socket.disconnect();
        // 清除
        window.clearInterval(int);
      }
    });
  }, YUNM._set.interval);
  callback();
}


####③、需要web推送的页面进行socketio的连接


$(function() {
connectQuotation($("#global_uid").val(), function() {
  socket.on("pushQuotation", function(message) {
  if (message.type == "dealOrder") {
    var msg = message.response.result;
    // 输出服务端消息
    YUNM.debug(msg);
  }
  });
});
});


相关文章
|
4月前
|
消息中间件 监控 Java
利用Java构建高效的消息推送系统
利用Java构建高效的消息推送系统
|
6月前
|
监控 JavaScript API
局域网监控软件的实时通知系统:利用Node.js和WebSocket实现即时消息推送
本文介绍了如何使用Node.js和WebSocket构建局域网监控软件的实时通知系统。实时通知对于网络安全和家庭监控至关重要,能即时发送监控数据变化的通知,提高响应速度。通过Node.js创建WebSocket服务器,当数据变化时,监控软件发送消息至服务器,服务器随即推送给客户端。此外,还展示了如何利用Node.js编写API,自动将监控数据提交到网站,便于用户查看历史记录,从而提升监控体验。
176 3
|
3月前
|
网络协议 C# 开发者
WPF与Socket编程的完美邂逅:打造流畅网络通信体验——从客户端到服务器端,手把手教你实现基于Socket的实时数据交换
【8月更文挑战第31天】网络通信在现代应用中至关重要,Socket编程作为其实现基础,即便在主要用于桌面应用的Windows Presentation Foundation(WPF)中也发挥着重要作用。本文通过最佳实践,详细介绍如何在WPF应用中利用Socket实现网络通信,包括创建WPF项目、设计用户界面、实现Socket通信逻辑及搭建简单服务器端的全过程。具体步骤涵盖从UI设计到前后端交互的各个环节,并附有详尽示例代码,助力WPF开发者掌握这一关键技术,拓展应用程序的功能与实用性。
107 0
|
3月前
|
存储 网络协议 Java
【Netty 神奇之旅】Java NIO 基础全解析:从零开始玩转高效网络编程!
【8月更文挑战第24天】本文介绍了Java NIO,一种非阻塞I/O模型,极大提升了Java应用程序在网络通信中的性能。核心组件包括Buffer、Channel、Selector和SocketChannel。通过示例代码展示了如何使用Java NIO进行服务器与客户端通信。此外,还介绍了基于Java NIO的高性能网络框架Netty,以及如何用Netty构建TCP服务器和客户端。熟悉这些技术和概念对于开发高并发网络应用至关重要。
64 0
|
3月前
|
JavaScript 前端开发 网络协议
WebSocket在Java Spring Boot+Vue框架中实现消息推送功能
在现代Web应用中,实时消息提醒是一项非常重要的功能,能够极大地提升用户体验。WebSocket作为一种在单个TCP连接上进行全双工通信的协议,为实现实时消息提醒提供了高效且低延迟的解决方案。本文将详细介绍如何在Java Spring Boot后端和Vue前端框架中利用WebSocket实现消息提醒功能。
141 0
|
5月前
|
监控 网络协议 Java
Java一分钟之-Netty:高性能异步网络库
【6月更文挑战第11天】Netty是Java的高性能异步网络框架,基于NIO,以其高吞吐量、低延迟、灵活性和安全性受到青睐。常见问题包括内存泄漏、ChannelHandler滥用和异常处理不当。要规避这些问题,需正确释放ByteBuf,精简ChannelPipeline,妥善处理异常,并深入理解Netty原理。通过代码审查、遵循最佳实践和监控日志,可提升代码质量和性能。掌握Netty,打造高效网络服务。
79 2
|
4月前
|
安全 NoSQL Java
网络安全-----Redis12的Java客户端----客户端对比12,Jedis介绍,使用简单安全性不足,lettuce(官方默认)是基于Netty,支持同步,异步和响应式,并且线程是安全的,支持R
网络安全-----Redis12的Java客户端----客户端对比12,Jedis介绍,使用简单安全性不足,lettuce(官方默认)是基于Netty,支持同步,异步和响应式,并且线程是安全的,支持R
|
6月前
|
编解码 前端开发 Java
Java网络API之Netty深度解析
Java网络API之Netty深度解析
52 0
|
6月前
|
编解码 网络协议 Java
用Java的BIO和NIO、Netty实现HTTP服务器(一) BIO与绪论
用Java的BIO和NIO、Netty实现HTTP服务器(一) BIO与绪论
|
6月前
|
前端开发 Java 数据库连接
认识Java中最常用的框架:Spring、Spring MVC、Spring Boot、MyBatis和Netty
Spring框架 Spring是一个轻量级的开源框架,用于构建企业级应用。它提供了广泛的功能,包括依赖注入、面向切面编程、事务管理、消息传递等。Spring的核心思想是控制反转(IoC)和面向切面编程(AOP)。
256 3