首页 / JAVA / Java搭建WebSocket的两种方式

Java搭建WebSocket的两种方式

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Java搭建WebSocket的两种方式，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含15717字，纯文字阅读大概需要23分钟。

内容图文

下面分别介绍搭建方法：
一、直接使用Java EE的api进行搭建。
一共3个步骤：
1、添加依赖
<dependency>
<groupId>javax</groupId>
<artifactId>javaee-api</artifactId>
<version>7.0</version>
<scope>provided</scope>
</dependency>
2、使用注解@ServerEndpoint
import javax.websocket.*;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.logging.Logger;

/**
* WebSocket连接 sessionKey是url中的参数
*/
@ServerEndpoint("/websocket/{sessionKey}")
public class WebSocket {

private static final Logger log = Logger.getLogger(WebSocket.class.getName());

//静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。
private static int onlineCount = 0;

//concurrent包的线程安全，用来存放每个客户端对应的MyWebSocket对象。若要实现服务端与单一客户端通信的话，可以使用Map来存放，其中Key可以为用户标识
private static Map<String, WebSocket> webSockets = new ConcurrentHashMap<>();

//与某个客户端的连接会话，需要通过它来给客户端发送数据
private Session session;

/**
   * 连接建立成功调用的方法
   *
   * @param session 可选的参数。session为与某个客户端的连接会话，需要通过它来给客户端发送数据
   * @param sessionKey url地址参数
   */
@OnOpen
public void onOpen(Session session, @PathParam("sessionKey") String sessionKey) {

      if (!webSockets.containsKey(sessionKey)) {
         this.session = session;
         webSockets.put(sessionKey, this);
         addOnlineCount();
         log.info("当前websocket连接数：" + onlineCount);
      }
}

/**
   * 连接关闭调用的方法
   *
   * @param sessionKey url地址参数
   */
@OnClose
public void onClose(@PathParam("sessionKey") String sessionKey) {

      if (webSockets.containsKey(sessionKey)) {
         webSockets.remove(sessionKey);
         subOnlineCount();
         log.info("当前websocket连接数：" + onlineCount);
      }
}

/**
   * 收到客户端消息后调用的方法
   *
   * @param message 客户端发送过来的消息
   * @param session 可选的参数
   */
@OnMessage
public void onMessage(String message, Session session) {
      log.info("来自客户端的消息:" + message);
}

/**
   * 发生错误时调用
   *
   * @param session 可选的参数
   * @param error 错误消息
   */
@OnError
public void one rror(Session session, Throwable error) {
      log.info("websocket发生错误：" + error);
}

/**
   * 该方法没有用注解，是根据自己需要添加的方法。在自己的业务中调用，发送消息给前端。
   *
   * @param sessionKey
   * @param message 返回的结果
   * @throws IOException
   */
public static void sendMessage(String sessionKey, String message) throws IOException {

      WebSocket webSocket = webSockets.get(sessionKey);

      if (null != webSocket) {

         log.info("websocket发送消息：" + message);

         //同步发送发送第二条时，必须等第一条发送完成
         webSocket.session.getBasicRemote().sendText(message);

         //异步发送
         //webSocket.session.getAsyncRemote().sendText(message);
      }
}

public static synchronized int getOnlineCount() {
      return onlineCount;
}

public static synchronized void addOnlineCount() {
      onlineCount++;
}

public static synchronized void subOnlineCount() {
      onlineCount--;
}

}
3、测试
在线WebSocket测试：http://coolaf.com/tool/chattest
输入地址进行测试即可，举例：ws://localhost:8080/websocket/sessionKey
补充：也可以使用java搭建客户端程序测试，测试的例程放到后面去了~~
二、和springboot整合的WebSocket服务(功能更加强大)
看下效果：<ignore_js_op> Java搭建WebSocket的两种方式 - 文章图片
<ignore_js_op>

http://localhost:8080/websocket/sendToUser?username=river&info=你找我干嘛？

Java搭建WebSocket的两种方式 - 文章图片

maven依赖如下：

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-websocket</artifactId>

<version>2.0.4.RELEASE</version>

</dependency>

1、控制类

package com.boot.river.websocket;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RequestParam;

import org.springframework.web.bind.annotation.ResponseBody;

import org.springframework.web.socket.TextMessage;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpSession;

@Controller

@RequestMapping(value = "/websocket", method = {RequestMethod.POST, RequestMethod.GET})/*GET请求开放用于测试，最好只允许POST请求*/

public class WebSocketController {

@Autowired

SpringWebSocketHandler springWebSocketHandler;

/**

* 登录将username放入session中，然后在拦截器HandshakeInterceptor中取出

@ResponseBody

@RequestMapping("/login")

public String login(HttpServletRequest request, @RequestParam(value = "username") String username, @RequestParam(value = "password") String password) {

System.out.println("登录：" + username + "：" + password);

HttpSession session = request.getSession();

if (null != session) {

session.setAttribute("SESSION_USERNAME", username);

return "success";

} else {

return "fail";

}

/**

* 指定发送

@ResponseBody

@RequestMapping("/sendToUser")

public String send(@RequestParam(value = "username") String username, @RequestParam(value = "info") String info) {

springWebSocketHandler.sendMessageToUser(username, new TextMessage(info));

System.out.println("发送至：" + username);

return "success";

}

/**

* 广播

@ResponseBody

@RequestMapping("/broadcast")

public String broadcast(@RequestParam(value = "info") String info) {

springWebSocketHandler.sendMessageToUsers(new TextMessage("广播消息：" + info));

System.out.println("广播成功");

return "success";

}

2、配置类（实现WebSocketConfigurer接口）

@Configuration

@EnableWebSocket

public class SpringWebSocketConfig implements WebSocketConfigurer {

public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {

registry.addHandler(getSpringWebSocketHandler(), "/websocket/server")

.addInterceptors(getInterceptor()).setAllowedOrigins("*");

registry.addHandler(getSpringWebSocketHandler(), "/sockjs/server").setAllowedOrigins("*")

.addInterceptors(getInterceptor()).withSockJS();

}

@Bean

public SpringWebSocketHandler getSpringWebSocketHandler() {

return new SpringWebSocketHandler();

}

@Bean

public SpringWebSocketHandlerInterceptor getInterceptor() {

return new SpringWebSocketHandlerInterceptor();

}

3、处理类（实现了WebSocketHandler接口）

package com.boot.river.websocket;

import org.springframework.web.socket.CloseStatus;

import org.springframework.web.socket.TextMessage;

import org.springframework.web.socket.WebSocketSession;

import org.springframework.web.socket.handler.TextWebSocketHandler;

import java.io.IOException;

import java.util.HashMap;

import java.util.Map;

public class SpringWebSocketHandler extends TextWebSocketHandler {

/**

* 存储用户id和其对应的session

private static final Map<String, WebSocketSession> users = new HashMap<>();

/**

* 用户名key值

private static final String USER_ID = "WEBSOCKET_USERID";

/**

* 连接建立后触发

@Override

public void afterConnectionEstablished(WebSocketSession session) {

System.out.println("成功建立websocket连接!");

String userId = (String) session.getAttributes().get(USER_ID);//取出在拦截器中存储的username

users.put(userId, session);

System.out.println("当前线上用户数量:" + users.size());

}

/**

* 关闭连接时触发

@Override

public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) {

String userId = (String) session.getAttributes().get(USER_ID);

System.out.println("用户" + userId + "已退出！");

users.remove(userId);

System.out.println("剩余在线用户" + users.size());

}

/**

* 接收消息

@Override

protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {

super.handleTextMessage(session, message);

System.out.println("收到消息：" + message);

if (message.getPayload().contains("在吗")) {

session.sendMessage(new TextMessage("对方不在线！"));

}

public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {

if (session.isOpen()) {

session.close();

}

System.out.println("传输出现异常，关闭websocket连接... ");

String userId = (String) session.getAttributes().get(USER_ID);

users.remove(userId);

}

public boolean supportsPartialMessages() {

return false;

}

/**

* 给某个用户发送消息

public void sendMessageToUser(String userId, TextMessage message) {

for (String id : users.keySet()) {

if (id.equals(userId)) {

try {

if (users.get(id).isOpen()) {

users.get(id).sendMessage(message);

}

} catch (IOException e) {

e.printStackTrace();

}

break;

}

/**

* 给所有在线用户发送消息

public void sendMessageToUsers(TextMessage message) {

for (String userId : users.keySet()) {

try {

if (users.get(userId).isOpen()) {

users.get(userId).sendMessage(message);

}

} catch (IOException e) {

e.printStackTrace();

}

4、拦截器（实现HandshakeInterceptor接口）

package com.boot.river.websocket;

import org.springframework.http.server.ServerHttpRequest;

import org.springframework.http.server.ServerHttpResponse;

import org.springframework.http.server.ServletServerHttpRequest;

import org.springframework.web.socket.WebSocketHandler;

import org.springframework.web.socket.server.support.HttpSessionHandshakeInterceptor;

import javax.servlet.http.HttpSession;

import java.util.Map;

public class SpringWebSocketHandlerInterceptor extends HttpSessionHandshakeInterceptor {

@Override

public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler,

Map<String, Object> attributes) throws Exception {

System.out.println("Before Handshake");

if (request instanceof ServletServerHttpRequest) {

ServletServerHttpRequest servletRequest = (ServletServerHttpRequest) request;

HttpSession session = servletRequest.getServletRequest().getSession(false);//获取session时，如果没有则返回null

if (session != null) {

String userName = (String) session.getAttribute("SESSION_USERNAME");//在登录时保存的用户名

if (userName != null) {

attributes.put("WEBSOCKET_USERID", userName);//放入attributes中，可以在处理器的WebSocketSession中取出

}

return super.beforeHandshake(request, response, wsHandler, attributes);

}

@Override

public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler,

Exception ex) {

super.afterHandshake(request, response, wsHandler, ex);

System.out.println("after Handshake");

}

参考：

https://my.oschina.net/u/3445245/blog/3003208

https://blog.csdn.net/runbat/article/details/80985944

https://docs.spring.io/spring/docs/5.0.0.BUILD-SNAPSHOT/spring-framework-reference/html/websocket.html

下面分别介绍websocket的java客户端请求和js客户端请求

1、java客户端

添加依赖：

<groupId>org.java-websocket</groupId>

<artifactId>Java-WebSocket</artifactId>

</dependency>

package com.river.websocket;

import org.java_websocket.enums.ReadyState;

import java.net.URISyntaxException;

/**

* @author river

* @date 2019-12-6

public class Client {

public static void main(String[] args) throws URISyntaxException, InterruptedException {

MyWebSocketClient client = new MyWebSocketClient("ws://localhost:8080/websocket/server");

client.connect();

while (client.getReadyState() != ReadyState.OPEN) {

System.out.println("连接状态：" + client.getReadyState());

Thread.sleep(100);

}

client.send("测试数据！");

client.close();

}

继承WebsocketClient

package com.river.websocket;

import org.java_websocket.client.WebSocketClient;

import org.java_websocket.handshake.ServerHandshake;

import java.net.URI;

import java.net.URISyntaxException;

public class MyWebSocketClient extends WebSocketClient {

MyWebSocketClient(String url) throws URISyntaxException {

super(new URI(url));

}

@Override

public void onOpen(ServerHandshake shake) {

System.out.println(shake.getHttpStatusMessage());

}

@Override

public void onMessage(String paramString) {

System.out.println(paramString);

}

@Override

public void onClose(int paramInt, String paramString, boolean paramBoolean) {

System.out.println("关闭");

}

@Override

public void one rror(Exception e) {

System.out.println("发生错误");

}

2、js客户端

<!DOCTYPE html>

<html>

<head>

<title>websocket</title>

var websocket = null;

if ('WebSocket' in window) {

websocket = new WebSocket("ws://localhost:8080/websocket/server");

} else if ('MozWebSocket' in window) {

websocket = new MozWebSocket("ws://localhost:8080/websocket/server");

} else {

websocket = new SockJS("http://localhost:8080/sockjs/server");

}

websocket.onopen = onOpen;

websocket.onmessage = onMessage;

websocket.onerror = one rror;

websocket.onclose = onClose;

function onOpen(event) {

alert(event.type);

}

function onMessage(messageEvent) {

alert(messageEvent.data);

}

function one rror(event) {

}

function onClose(closeEvent) {

alert(closeEvent.reason);

}

function doSendUser() {

if (websocket.readyState === websocket.OPEN) {

var msg = document.getElementById("inputMsg").value;

websocket.send(msg);//发送消息

alert("发送成功!");

} else {

alert("连接失败!");

}

window.close = function () {

websocket.onclose();

};

function websocketClose() {

websocket.close();

alert("连接关闭");

}

</script>

</head>

<body>

请输入：<input id="inputMsg" name="inputMsg"/>

</body>

</html>

补充：登录方式除了在Controller中处理，还可以在Websocket中接收到的消息进行登录处理。

更多java学习资料可关注:itheimaGZ获取

内容总结

以上是互联网集市为您收集整理的Java搭建WebSocket的两种方式全部内容，希望文章能够帮你解决Java搭建WebSocket的两种方式所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/640846.html

来源：【匿名】

【上一篇】Java 静态代理【下一篇】JAVA/JSP学习系列之五

更多 ►

【Java搭建WebSocket的两种方式】教程文章相关的互联网学习教程文章

Java WebSocket基本原理【代码】【图】

WebSocket协议介绍 WebSocket协议是一个网络协议，允许两个相连的端在一个单一TCP连接上进行全双工消息通信。在WebSocket的场景中，连接通过HTTP和WebSocket端点交互的方式建立。连接的一方发送一个专门定制的HTTP请求，启动包含其希望连接的WebSocket的URL。它开始活动并被称为打开阶段握手。如果服务器愿意接受连接，服务器制定一个称为打开阶段握手响应的特殊的HTTP响应并将其发送会客户端。此时TCP连接已经建立，能够保...

java websocket【代码】

import org.springframework.web.socket.server.standard.SpringConfigurator;import javax.websocket.*; import javax.websocket.server.ServerEndpoint; import java.io.IOException; import java.util.concurrent.CopyOnWriteArraySet;/*** Created by wfcfa on 2016/3/15.*///该注解用来指定一个URI，客户端可以通过这个URI来连接到WebSocket。类似Servlet的注解mapping。无需在web.xml中配置。 @ServerEndpoint(value = "/web...

【最新】主流JAVA框架 springmvc mybaits websocket 服务器框架【图】

获取【下载地址】? ?QQ: 313596790? ?【免费支持更新】A 代码生成器(开发利器);? ? B 阿里巴巴数据库连接池druid;??数据库连接池??阿里巴巴的 druid。Druid在监控、可扩展性、稳定性和性能方面都有明显的优势C 安全权限框架shiro ;??D ehcache 自定义二级缓存;E 微信接口开发（后续会加入Activiti5 工作流）免费升级----------------------------------------------------------------------------------------------------------...

springboot整合websocket后打包报错：javax.websocket.server.ServerContainer not available【代码】【图】

项目整合了websocket以后，打包多次都没有成功，原来是报错了，报错内容如下：Error starting ApplicationContext. To display the conditions report re-run your application with ‘debug‘ enabled. org.springframework.boot.SpringApplication.reportFailure(SpringApplication.java:837) 2020-03-18 08:20:02,192 [main] ERROR pringApplication - Application run failed org.springframework.beans.factory.BeanCreationE...

java使用websocket，并且获取HttpSession，源码分析【代码】【图】

一：本文使用范围此文不仅仅局限于spring boot，普通的spring工程，甚至是servlet工程，都是一样的，只不过配置一些监听器的方法不同而已。本文经过作者实践，确认完美运行。二：Spring boot使用websocket2.1:依赖包websocket本身是servlet容器所提供的服务，所以需要在web容器中运行，像我们所使用的tomcat，当然，spring boot中已经内嵌了tomcat。websocket遵循了javaee规范，所以需要引入javaee的包 <dependency><groupId>jav...

在Java7与Tomcat8环境下使用WebSocket实现聊天的示例【代码】【图】

文中案例在apache-tomcat-8.0.15和jdk1.8.0_25环境下开发，运行。不过标题上是Java7,并不造成影响，代码中没有涉及任何与jdk1.8.x相关的代码。另外之所以要讲清软件版本，一是为了保证案例能够有个明确的实现背景，二是websocket实现tomcat7.x与tomcat8.x有很大差异。在JavaEE规范集中我们这里主要看Java API for WebSocket(JSR 356)。Websocket-api提供了Java实现Websocket的接口，其中最重要的几个类和注解如下图： 650) t...

集成websocket即时通讯 java聊天源码代码下载 java后台框架源码 websocket源码 IM【图】

获取【下载地址】? ?QQ: 313596790? ?【免费支持更新】支持三大数据库 mysql??oracle??sqlsever? ?更专业、更强悍、适合不同用户群体【新录针对本系统的视频教程，手把手教开发一个模块，快速掌握本系统】A 代码生成器(开发利器);? ?? ?增删改查的处理类，service层，mybatis的xml，SQL( mysql? ?和oracle)脚本,? ?jsp页面都生成? ?就不用写搬砖的代码了,生成的放到项目里，可以直接运行B 阿里巴巴数据库连接池druid;??数据库连接...

java 实现websocket(转)【代码】【图】

前端：<%@ page language="java" import="java.util.*" pageEncoding="UTF-8" %> <%String path = request.getContextPath();String basePath = request.getScheme() + "://"+ request.getServerName() + ":" + request.getServerPort()+ path + "/";String ppp = request.getServerName() + ":" + request.getServerPort()+ path + "/";%><!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"> <html> <head><base hr...

Java后台使用Websocket教程【代码】

在开发一个项目的时候使用到了WebSocket协议什么是WebSocket?　　　　　　　　WebSocket使得客户端和服务器之间的数据交换变得更加简单，允许服务端主动向客户端推送数据。在WebSocket API中，浏览器和服务器只需要完成一次握手，两者之间就直接可以创建持久性的连接，并进行双向数据传输。　　 2.使用工具类　1package com.mz.usps.common.component;2 3import org.apache.log4j.Logger;4import org.springframework.stereotype...

【最新】主流JAVA框架 springmvc mybaits websocket 服务器框架【图】

【集成websocket即时通讯】javaEE 后台框架 SpringMVC Mybatis Shiro druid Bootstrap HTML5 hiber【图】

基于websocket的jsp与java进行交互【代码】【图】

环境:jdk.18 tomcat-7.0.70把tomcat中的两个jir包复制到注意:最后部署的时候要删除掉这两个jar包 tomcate中已经有了ebSocket对象的创建和服务器连接要连接通信端点，只需要创建一个新的WebSocket实例，并提供希望连接的对端URL。ws://和wss://前缀分别表示WebSocket连接和安全的WebSocket连接。url = "ws://localhost:8080/echo"; w = new WebSocket(url); 建立WebSocket连接时，可以列出Web应用能够使用的协议var ws; window....

javascript中WebSocket用法【代码】【图】

一.概念websocket定义WebSocket是html5提供的一种在单个TCP连接上进行双向通信的协议，解决了客户端和服务端之间的实时通信问题。浏览器和服务器只需完成一次握手，两者之间就可以创建一个持久性的TCP连接，此后服务器和客户端通过此TCP连接进行双向实时通信。websocket优点很多网站为了实现数据推送，所用的技术都是ajax轮询。轮询是在特定的时间间隔，由浏览器主动发起请求，将服务器的数据拉回来。轮询需要不断的向服务器发送请...

实现 WebSocket 断开自动重连的 JavaScript 库【代码】

ReconnectingWebSocket 是一个小型的 JavaScript 库，封装了 WebSocket API 提供了在连接断开时自动重连的机制。只需要简单的将：ws = new WebSocket(‘ws://....‘);替换成：ws = new ReconnectingWebSocket(‘ws://....‘); 详见：https://github.com/fc653074701/reconnecting-websocket 或者： //间隔发送心跳包数据给服务器，服务器在一定时间内发回心跳包响应，对比超时限定，如果超过设定的超时时间，则认为当前与服务器的...

【集成websocket即时通讯】javaEE 后台框架 SpringMVC Mybatis Shiro druid Bootstrap HTML5【图】

首页 / JAVA / Java搭建WebSocket的两种方式

Java搭建WebSocket的两种方式

内容导读

内容图文

内容总结

内容备注

内容手机端

【Java搭建WebSocket的两种方式】教程文章相关的互联网学习教程文章

Java WebSocket基本原理【代码】【图】

java websocket【代码】

【最新】主流JAVA框架 springmvc mybaits websocket 服务器框架【图】

springboot整合websocket后打包报错：javax.websocket.server.ServerContainer not available【代码】【图】

java使用websocket，并且获取HttpSession，源码分析【代码】【图】

在Java7与Tomcat8环境下使用WebSocket实现聊天的示例【代码】【图】

集成websocket即时通讯 java聊天源码代码下载 java后台框架源码 websocket源码 IM【图】

java 实现websocket(转)【代码】【图】

Java后台使用Websocket教程【代码】

【最新】主流JAVA框架 springmvc mybaits websocket 服务器框架【图】

【集成websocket即时通讯】javaEE 后台框架 SpringMVC Mybatis Shiro druid Bootstrap HTML5 hiber【图】

基于websocket的jsp与java进行交互【代码】【图】

javascript中WebSocket用法【代码】【图】

实现 WebSocket 断开自动重连的 JavaScript 库【代码】

【集成websocket即时通讯】javaEE 后台框架 SpringMVC Mybatis Shiro druid Bootstrap HTML5【图】

WEBSOCKET - 相关标签

JAVA - 相关标签

JAVA - 技术教程分类

JAVA - 最新教程

JAVA - 最热教程