技术标签： websocket spring boot websocket token 鉴权
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;
/**
* @ClassName WebSocketConfig
* @Description: websocket集成配置
* @Author
* @Date 2020/1/2 16:56
* @Version V1.0
**/
@Configuration
public class WebSocketConfig {
/**
* 服务器节点
*
* @return
*/
@Bean
public ServerEndpointExporter serverEndpointExporter() {
return new ServerEndpointExporter();
}
}
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import javax.servlet.http.HttpServletRequest;
import javax.websocket.HandshakeResponse;
import javax.websocket.server.HandshakeRequest;
import javax.websocket.server.ServerEndpointConfig;
/**
* @ClassName ServerConfigurator
* @Description: server 配置，进行行为修改，鉴权等曹邹
* @Author
* @Date 2020/1/4 11:11
* @Version V1.0
**/
@Slf4j
@Component
public class ServerConfigurator extends ServerEndpointConfig.Configurator {
/**
* token鉴权认证 临时写死123
* @param originHeaderValue
* @return
*/
@Override
public boolean checkOrigin(String originHeaderValue) {
ServletRequestAttributes servletRequestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
HttpServletRequest request = servletRequestAttributes.getRequest();
String token = request.getParameter("token");
LogUtil.info(log,"---->>>>> token {0}",token);
if("123".equals(token)) {
return super.checkOrigin(originHeaderValue);
}else{
return false;
}
}
/**
* Modify the WebSocket handshake response
* 修改websocket 返回值
* @param sec
* @param request
* @param response
*/
@Override
public void modifyHandshake(ServerEndpointConfig sec, HandshakeRequest request, HandshakeResponse response) {
super.modifyHandshake(sec, request, response);
}
}
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.websocket.*;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.concurrent.CopyOnWriteArraySet;
import java.util.concurrent.Future;
import java.util.concurrent.atomic.AtomicInteger;
/**
* @ClassName WebSocketServer
* @Description: websocket 服务处理核心类 sid 请求唯一标识 不能重复
* @Author
* @Date 2020/1/2 17:00
* @Version V1.0
**/
@ServerEndpoint(value = "/websocket/{sid}", configurator = ServerConfigurator.class)
@Component
@Slf4j
public class WebSocketServer {
//静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。
private AtomicInteger onlineCount = new AtomicInteger();
//concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。
private static CopyOnWriteArraySet<WebSocketServer> webSocketSet = new CopyOnWriteArraySet<WebSocketServer>();
//与某个客户端的连接会话，需要通过它来给客户端发送数据
private Session session;
//接收sid 请求唯一标识
private String sid = "";
/**
* 连接建立成功调用的方法
*/
@OnOpen
public void onOpen(Session session, @PathParam(value = "sid") String sid) {
this.session = session;
webSocketSet.add(this); //加入set中
addOnlineCount(); //在线数加1
this.sid = sid;
LogUtil.info(log,"有新窗口开始监听:" + sid + ",当前在线人数为" + getOnlineCount());
LogUtil.info(log, "cid ---->>>{0}", sid);
try {
sendMessage("连接成功");
} catch (IOException e) {
log.error("websocket IO异常");
}
}
/**
* 连接关闭调用的方法
*/
@OnClose
public void onClose() {
webSocketSet.remove(this); //从set中删除
subOnlineCount(); //在线数减1
LogUtil.info(log,"有一连接关闭！当前在线人数为" + getOnlineCount());
}
/**
* 收到客户端消息后调用的方法
*
* @param message 客户端发送过来的消息
*/
@OnMessage
public void onMessage(String message, Session session) {
LogUtil.info(log,"收到来自窗口" + sid + "的信息:" + message);
//群发消息
for (WebSocketServer item : webSocketSet) {
try {
item.sendMessage(message);
} catch (IOException e) {
e.printStackTrace();
}
}
}
/**
* @param session
* @param error
*/
@OnError
public void onError(Session session, Throwable error) {
LogUtil.error(log,"websocket发生错误");
error.printStackTrace();
}
/**
* 当前客户端发送消息
* 实现服务器主动推送
*/
public void sendMessage(String message) throws IOException {
this.session.getBasicRemote().sendText(message);
}
/**
* 异步推送消息
*
* @param message
*/
public static void sendWholeAsyncMessage(String message) {
for (WebSocketServer item : webSocketSet) {
try {
item.session.getAsyncRemote().sendText(message);
} catch (Exception e) {
LogUtil.error(log,"websocket异步发送消息异常{0}",e);
continue;
}
}
}
/**
* 群发自定义消息
*/
public static void sendInfo(@PathParam("sid") String sid, String message) throws IOException {
LogUtil.error(log,"推送消息到窗口" + sid + "，推送内容:" + message);
for (WebSocketServer item : webSocketSet) {
try {
//这里可以设定只推送给这个sid的，为null则全部推送
if (sid == null) {
item.sendMessage(message);
} else if (item.sid.equals(sid)) {
item.sendMessage(message);
}
} catch (IOException e) {
LogUtil.error(log,"websocket发送消息异常{0}",e);
continue;
}
}
}
private int getOnlineCount() {
return onlineCount.get();
}
private void addOnlineCount() {
onlineCount.incrementAndGet();
}
private void subOnlineCount() {
onlineCount.decrementAndGet();
}
}
import lombok.extern.slf4j.Slf4j;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.concurrent.CountDownLatch;
/**
* @ClassName WebSocketClientTest
* @Description: web socket test 类
* @Author
* @Date 2020/1/6 9:54
* @Version V1.0
**/
@Slf4j
public class WebSocketClientTest extends Thread {
private String uri;
private CountDownLatch countDownLatch;
public WebSocketClientTest(String uri, CountDownLatch countDownLatch) {
this.uri = uri;
this.countDownLatch=countDownLatch;
}
@Override
public void run() {
getClient(uri);
try {
countDownLatch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
/**
* 获取客户端连接实例
*
* @param uri
* @return
*/
public WebSocketClient getClient(String uri) {
try {
//创建客户端连接对象
WebSocketClient client = new WebSocketClient(new URI(uri)) {
/**
* 建立连接调用
* @param serverHandshake
*/
@Override
public void onOpen(ServerHandshake serverHandshake) {
log.info(uri+"===建立连接===");
}
/**
* 收到服务端消息调用
* @param s
*/
@Override
public void onMessage(String s) {
log.info(uri+"====收到来自服务端的消息===" + s);
}
/**
* 断开连接调用
* @param i
* @param s
* @param b
*/
@Override
public void onClose(int i, String s, boolean b) {
log.info("关闭连接:::" + "i = " + i + ":::s = " + s + ":::b = " + b);
}
/**
* 连接报错调用
* @param e
*/
@Override
public void onError(Exception e) {
log.error("====出现错误====" + e.getMessage());
}
};
//请求与服务端建立连接
client.connect();
//判断连接状态，0为请求中 1为已建立 其它值都是建立失败
while (client.getReadyState().ordinal() == 0) {
try {
Thread.sleep(200);
} catch (Exception e) {
log.warn("延迟操作出现问题，但并不影响功能");
}
log.info("连接中.......");
}
//连接状态不再是0请求中，判断建立结果是不是1已建立
if (client.getReadyState().ordinal() == 1) {
return client;
}
if (!(client.getReadyState().ordinal() == 1 || client.getReadyState().ordinal() == 0)) {
log.info(uri+"连接失败.......");
}
} catch (URISyntaxException e) {
log.error(e.getMessage());
}
return null;
}
import java.util.concurrent.CountDownLatch;
/**
* @ClassName WebSocketTest
* @Description: websocket 并发测试类
* @Author
* @Date 2020/1/6 10:00
* @Version V1.0
**/
public class WebSocketTest {
public static void main(String[] args) {
String urlPre = "ws://localhost:9029/websocket/";
int threadNum = 1000;
CountDownLatch countDownLatch = new CountDownLatch(threadNum);
for (int i = 0; i < threadNum; i++) {
String url = urlPre +"NO"+i+"?token=123";
new WebSocketClientTest(url, countDownLatch).start();
countDownLatch.countDown();
}
}
}
<!-- websocket begin -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
<dependency>
<groupId>org.java-websocket</groupId>
<artifactId>Java-WebSocket</artifactId>
<version>1.4.0</version>
</dependency>
<!-- websocket end -->
websocket 集群建议使用token 集中存储管理
文章浏览阅读5.4w次，点赞89次，收藏746次。java常见面试题_java面试题
文章浏览阅读5.4k次，点赞6次，收藏73次。编程总结每每刷完一道题后，其思想和精妙之处没有地方记录，本篇博客用以记录刷题过程中的遇到的算法和技巧001）两数之和给定一个整数数组 nums 和一个目标值 target，请你在该数组中找出和为目标值的两个整数。你可以假设每种输入只会对应一个答案。但是，你不能重复利用这个数组中同样的元素。给定 nums = [2, 7, 11, 15], target = 9因为 nums[0] ..._leetcode c语言
文章浏览阅读125次。检查请求头中的’sec-fetch-dest’: ‘document’ ，是否进行了特殊处理（node层）_苹果 sec-fetch-dest
文章浏览阅读321次。服务器初始化（这是在建立在新的服务器基础上做的初始化）关闭防火墙、selinux，添加epel常用源，安装常用工具、添加普通用户并禁止root1、服务器批量初始化[root@fwd ansible]# cat init.yml 系统初始化脚本---- hosts: all tasks: - name: disable selinux、firew..._ansible批量安装zabbix-agent
文章浏览阅读1.4w次，点赞3次，收藏2次。Logger.getLogger(Test.class);从getLogger开始，就启动了log4j的整个工作流程，通过调用LogManager获取logger实例return LogManager.getLogger(clazz.getName());LogManager类里面有个静态块static{}，【初始化重要信息】【root logger】，做一些配置，其中url = Loader.ge_log4j 源码分析 读取配置
文章浏览阅读533次。无奈的父亲有一个美丽的小女孩，她的名字叫余艳，她有一双亮晶晶的大眼睛她有一颗透明的童心.她是一个孤儿，她在这个世界上只活了8年，她留在这个世界上最后的一句话是“我来过，我很乖”她希望死在秋天，纤瘦的身体就像一朵花自然开谢的过程.在遍地黄花堆积，落叶空中旋舞的时候，她会看见横空远行的雁儿们.她自愿放弃治疗，把全世界华人捐给她的54万分成了7份，把生命当成希望的蛋糕分给了7个正徘徊在生死线上的小
文章浏览阅读1.6k次，点赞42次，收藏35次。什么是牵引逆变器？从本质上讲，牵引逆变器是电动汽车动力系统中的一个子系统，它从电池中获取高电压，并将其转换为交流电压——因此被称为逆变器——并基本上为电机供电。它控制电机速度和扭矩，直接影响效率和可靠性，这正成为牵引逆变器设计的设计挑战。此图片来源于网络如今的电动汽车至少有一个牵引逆变器。有些型号实际上不止一个。一个在前轴上，一个在后轴上。甚至一些高端车型实际上每个车轮都有一个牵引逆变器。因此，效率和可靠性非常重要。所以，从逆变器和电机控制的市场趋势来看——从技术趋势来看，我们看到了功率水平的提高。
文章浏览阅读134次。简介apt-cache和apt-get是apt包的管理工具，他们根据/etc/apt/sources.list里的软件源地址列表搜索目标软件、并通过维护本地软件包列表来安装和卸载软件。查看本机是否安装软件：whereis package_name 或者which package_name1.搜索软件sudo apt-cache search pa..._ubuntu18.04 atp命令使用技巧
文章浏览阅读150次。【代码】查询Dynamics 365的Audit History。_dynamics 审核历史记录如何查询
文章浏览阅读1.3w次，点赞15次，收藏66次。什么是yield函数?yield函数是python里面的关键字,带有yield的函数相当于一个生成器generator.当你使用一个yield的时候，对应的函数就是一个生成器在python里面类似于return函数,他们主要的区别就是:遇到return会直接返回值,不会执行接下来的语句.但是yield并不是,在本次迭代返回之后,yield函数在下一次迭代时，从上一次迭代遇到的yield后面的代码(下一行)开始执行下面是案例分析:案例一:def gen_generator(): yiel_yield函数
文章浏览阅读917次。如果不用seek(0)的话，默认是自己会把读取文件的指针后移的，不用手动后移；_qfileread后指针会移动吗
文章浏览阅读2.5k次。整理了网上一份简单的dw8051测试示例，共享到云盘：http://pan.baidu.com/s/1bnu9lZT1.目录如下：---dut ---rtl：DW8051的core文件 ---model：ROM和RAM的model文件---testbench ---rtl.f：filelist文件 ---test_top.v：仿真的top_dw8051 part1