java 实现SocketIo客户端

#java 实现SocketIo客户端

这里主要是使用java实现SocketIo的客户端，接收长链接推送的消息，直接上代码

引入maven

     <dependency><groupId>io.socket</groupId><artifactId>socket.io-client</artifactId><version>2.0.1</version></dependency>

import io.socket.client.IO;
import io.socket.client.Socket;
import lombok.extern.slf4j.Slf4j;import java.net.URI;
import java.net.URLEncoder;
import java.util.Arrays;@Slf4j
public class SocketIoTest {public static void main(String[] args) throws Exception {SocketIoTest client = new SocketIoTest();final Socket socket = client.initSocket("https://ip:8888/user", "验证账号", "验证密码");Socket connect = socket.connect();socket.on("监听事件", objects -> {String s = Arrays.toString(objects);String substring = s.substring(1, s.length() - 1);System.out.println("长链接事件响应数据=========" + substring);});socket.on("另外一个event", objects -> {String s = Arrays.toString(objects);String substring = s.substring(1, s.length() - 1);System.out.println("另外一个event响应数据=========" + substring);});boolean connected = socket.connected();System.out.println(connected);}public Socket initSocket(String socketUrl, String accessKeyId, String accessKeySecret ) throws Exception {IO.Options options = new IO.Options();options.transports = new String[]{"websocket"};options.reconnection = false;System.out.println(accessKeySecret);String replace = URLEncoder.encode(accessKeySecret, "UTF-8");options.query = "id=" + accessKeyId + "&pwd=" + replace;URI uri = URI.create(socketUrl);final Socket socket = IO.socket(uri, options);socket.on(Socket.EVENT_CONNECT, objects -> System.out.println("client: " + "连接成功"));socket.on(Socket.EVENT_DISCONNECT, objects -> System.out.println("client: " + "连接断开"));socket.on(Socket.EVENT_CONNECT_ERROR, objects -> System.out.println("client: " + "连接失败"));socket.on("connection notice", objects -> {String s = Arrays.toString(objects);String substring = s.substring(1, s.length() - 1);System.out.println("链接通知=========" + substring);});boolean connected = socket.connected();return socket;}}

该代码根据实际服务端要求，还可以添加其他参数，根据实际情况而定，例如超时时间、是否重连等等。

java 实现SocketIo客户端相关推荐

CXF wsdl2java 生成java代码供客户端使用
CXF wsdl2java 生成java代码供客户端使用环境配置: 1.下载apache-cxf-2.6.2在环境变量中配置CXF_HOME 值为E:\gavin\cxf\apache-cxf-3. ...
java php 单点登陆,cas实现单点登录,登出(java跟php客户端)（转）
cas实现单点登录,登出(java跟php客户端)(转)cas实现单点登录,登出(java和php客户端) (转) 最近项目中需要做单点登录,客户端包含java和php,java有几个应用程序,php ...
基于netty访问WebSocket(java的websocket客户端)(访问远程ws协议)
1. 首先创建mvn项目 2. pom中导入jar包 <dependency><groupId>io.netty</groupId><artifactId&g ...
java写soap客户端_Java：简单的SOAP客户端
我正在寻找一个用于 Java的SOAP客户端. Apache Axis对我来说看起来很blo肿.我不明白为什么Java必须如此复杂.例如,在PHP中,我所要做的就是: $global_service_ ...
java chat_使用 Java 创建聊天客户端-1
1.聊天客户端文本框的搭建. 项目截图:java project 代码: (1).ChatManager.java package com.nantian.javachatclient.main; i ...
Java正确获取客户端真实IP方法整理
转载自干货:Java正确获取客户端真实IP方法整理在JSP里,获取客户端的IP地址的方法是:request.getRemoteAddr(),这种方法在大部分情况下都是有效的.但是在通过了Apach ...
smpp客户端_SMPP Java示例（客户端）
smpp客户端这篇文章通过创建一个简单的SMPP客户端向移动用户发送短信来提供SMPP Java示例,使用该客户端我们可以简单地提交以将消息发送给单个移动用户,也可以一次将消息广播给多个移动用户.另 ...
SMPP Java示例（客户端）
这篇文章通过创建一个简单的SMPP客户端向移动用户发送短信来提供SMPP Java示例,使用该客户端我们可以简单地提交以向单个移动用户发送消息,也可以一次将消息广播给多个移动用户.另外,我们将验证交货 ...
java服务器向客户端发消息_java一个简单的客户端向服务端发送消息
java一个简单的客户端向服务端发送消息客户端代码: package com.chenghu.tcpip; import java.io.IOException; import java.io.Ou ...

java 实现SocketIo客户端

java 实现SocketIo客户端相关推荐

最新文章

热门文章