后端 消息 转发_springCloud 后端使用webSocket向前端推送消息
1、webSocket
webSocket长连接是一种在单个tcp连接上进行全双工通信的协议,允许双向数据推送。一般微服务提供的restful API只是对前端请求做出相应。使用webSocket可以实现后端主动向前端推送消息。
2、springboot使用webSocket
1、pom文件添加依赖
org.springframework.boot
spring-boot-starter-websocket
2、添加webSocket配置
@Configuration
@EnableWebSocket
public class WebSocketAutoConfig implements WebSocketConfigurer {
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
// webSocket通道
// 指定处理器和路径
registry.addHandler(new WebSocketHandler(), "/websocket")
// 指定自定义拦截器
.addInterceptors(new WebSocketInterceptor())
// 允许跨域
.setAllowedOrigins("*");
// sockJs通道
registry.addHandler(new WebSocketHandler(), "/sock-js")
.addInterceptors(new WebSocketInterceptor())
.setAllowedOrigins("*")
// 开启sockJs支持
.withSockJS();
}
}
处理器代码:
import java.io.IOException;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import org.apache.commons.lang3.reflect.FieldUtils;
import org.springframework.stereotype.Component;
import org.springframework.web.socket.*;
import org.springframework.web.socket.handler.AbstractWebSocketHandler;
import org.springframework.web.socket.sockjs.transport.session.WebSocketServerSockJsSession;
@Component
public class WebSocketHandler extends AbstractWebSocketHandler {
/**
* 存储sessionId和webSocketSession
* 需要注意的是,webSocketSession没有提供无参构造,不能进行序列化,也就不能通过redis存储
* 在分布式系统中,要想别的办法实现webSocketSession共享
*/
private static Map sessionMap = new ConcurrentHashMap<>();
private static Map userMap = new ConcurrentHashMap<>();
/**
* 获取sessionId
*/
private String getSessionId(WebSocketSession session) {
if (session instanceof WebSocketServerSockJsSession) {
// sock js 连接
try {
return ((WebSocketSession) FieldUtils.readField(session, "webSocketSession", true)).getId();
} catch (IllegalAccessException e) {
throw new RuntimeException("get sessionId error");
}
}
return session.getId();
}
/**
* webSocket连接创建后调用
*/
@Override
public void afterConnectionEstablished(WebSocketSession session) {
// 获取参数
String user = String.valueOf(session.getAttributes().get("user"));
String sessionId = getSessionId(session);
userMap.put(user, getSessionId(session));
sessionMap.put(sessionId, session);
}
/**
* 接收到消息会调用
*/
@Override
public void handleMessage(WebSocketSession session, WebSocketMessage> message) throws Exception {
if (message instanceof TextMessage) {
} else if (message instanceof BinaryMessage) {
} else if (message instanceof PongMessage) {
} else {
System.out.println("Unexpected WebSocket message type: " + message);
}
}
/**
* 连接出错会调用
*/
@Override
public void handleTransportError(WebSocketSession session, Throwable exception) {
sessionMap.remove(getSessionId(session));
}
/**
* 连接关闭会调用
*/
@Override
public void afterConnectionClosed(WebSocketSession session, CloseStatus status) {
sessionMap.remove(getSessionId(session));
}
@Override
public boolean supportsPartialMessages() {
return false;
}
/**
* 后端发送消息
*/
public void sendMessage(String user, String message) {
String sessionId = userMap.get(user);
WebSocketSession session = sessionMap.get(sessionId);
try {
session.sendMessage(new TextMessage(message));
} catch (IOException e) {
e.printStackTrace();
}
}
}
自定义拦截器:
public class WebSocketInterceptor implements HandshakeInterceptor {
/**
* handler处理前调用,attributes属性最终在WebSocketSession里,可能通过webSocketSession.getAttributes().get(key值)获得
*/
@Override
public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Map attributes) {
if (request instanceof ServletServerHttpRequest) {
ServletServerHttpRequest serverHttpRequest = (ServletServerHttpRequest) request;
// 获取请求路径携带的参数
String user = serverHttpRequest.getServletRequest().getParameter("user");
attributes.put("user", user);
return true;
} else {
return false;
}
}
@Override
public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Exception exception) {
}
}
2、前端连接webSocket
WebSocket对象是H5新增的对象,低版本浏览器可能不支持,可以使用sockJs的方式连接
webSocket连接
// 打开一个 web socket
var ws = new WebSocket("ws://localhost:8080/websocket?user=Tony");
ws.onopen = function() {
// Web Socket 已连接上,使用 send() 方法发送数据
ws.send("测试发送");
console.log('open');
};
ws.onmessage = function (e) {
console.log('message', e.data);
};
ws.onclose = function() {
console.log('close');
};
sockJs连接
var sock = new SockJS('http://localhost:8080/sock-js?user=Tony');
sock.onopen = function() {
sock.send("测试发送");
console.log('open');
};
sock.onmessage = function(e) {
console.log('message', e.data);
};
sock.onclose = function() {
console.log('close');
};
3、springCloud使用zuul转发webSocket连接
zuul网关还需要做额外的配置,添加自定义过滤器:
@Component
public class WebSocketFilter extends ZuulFilter {
@Override
public String filterType() {
return "pre";
}
@Override
public int filterOrder() {
return 0;
}
@Override
public boolean shouldFilter() {
return true;
}
@Override
public Object run() {
RequestContext context = RequestContext.getCurrentContext();
HttpServletRequest request = context.getRequest();
String upgradeHeader = request.getHeader("Upgrade");
if (null == upgradeHeader) {
upgradeHeader = request.getHeader("upgrade");
}
if (null != upgradeHeader && "websocket".equalsIgnoreCase(upgradeHeader)) {
context.addZuulRequestHeader("connection", "Upgrade");
}
return null;
}
}
配置文件添加配置:
hystrix:
command:
default:
execution:
isolation:
thread:
timeoutInMilliseconds: 60000 #设置API网关中路由转发请求的HystrixCommand执行超时时间
ribbon:
ConnectTimeout: 3000 #设置路由转发请求的时候,创建请求连接的超时时间
ReadTimeout: 60000 #用来设置路由转发请求的超时时间
4、网关使用springCloud Gateway无需做任何处理
5、若使用了Nginx,需要添加配置
配置示例:
map $http_upgrade $connection_upgrade {
default upgrade;
'' close;
}
# 网关只有一个,写一个网关地址就行了
upstream [服务器组名] {
server [IP地址]:[端口号];
server [IP地址]:[端口号];
...
}
server {
listen 80;
location / {
proxy_pass http://[服务器组名];
proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection $connection_upgrade;
}
}
前端连接示例:
sockJs连接
var sock = new SockJS('http://(网关路径)/(服务名称)/sock-js?user=Tony');
sock.onopen = function() {
sock.send("测试发送");
console.log('open');
};
sock.onmessage = function(e) {
console.log('message', e.data);
};
sock.onclose = function() {
console.log('close');
};
webSocket连接
// 打开一个 web socket
var ws = new WebSocket("ws://(网关路径)/(服务名称)/websocket?user=Tony");
ws.onopen = function() {
// Web Socket 已连接上,使用 send() 方法发送数据
ws.send("测试发送");
console.log('open');
};
ws.onmessage = function (e) {
console.log('message', e.data);
};
ws.onclose = function() {
console.log('close');
};
后端 消息 转发_springCloud 后端使用webSocket向前端推送消息相关推荐
- SpringBoot使用Socket向前端推送消息
个人资源与分享网站:http://xiaocaoshare.com/ 1.对webSocket理解 WebSocket协议是基于TCP的一种新的网络协议.它实现了浏览器与服务器全双工(full-dup ...
- WebSocket + SpringBoot + VUE实现后端实时向前端推送消息
一.目的 众所周知,正常来说在前后端通信中,后端往往处于一个被动的状态,对前端的请求作出对应的响应.但有的时候我们会遇到需要后端前前端推送数据的需求,比如消息.邮件等的推送.这个时候,实现的一种方式是 ...
- 服务器如何向前端页面推送消息,后端向前端推送消息
SpringBoot+WebSocket集成 什么是WebSocket? 为什么需要 WebSocket? 前言 maven依赖 WebSocketConfig WebSocketServer 消息推 ...
- php推送消息到邮箱,thinkphp3.2通过PHPMailer发送邮件推送消息
thinkphp3.2通过PHPMailer发送邮件推送消息 1.首先下载PHPMailer: 2.在Controller中新增方法public function sendmail($title,$c ...
- 微信小程序推送消息java开发_干货 | 微信小程序推送消息简单Demo
在开始前,你需要准备:注册微信小程序 一个简单的springBoot 项目 微信开发者工具 正式 微信小程序发送消息主要通过WxMaTemplateMessage 类来推送 public class ...
- 苹果服务器消息转发,iphone-与APNS服务器进行交互以将推送通知发...
最好的方法是使用API??,例如以下服务提出的建议: >选择一个Saas API,将其连接到PHP / MySQL应用程序 >城市飞艇 > Pushwoosh > Wonder ...
- Netty实战,Springboot + netty +websocket 实现推送消息
开发者(KaiFaX) 面向全栈工程师的开发者专注于前端.Java/Python/Go/PHP的技术社区 来源 | blog.csdn.net/weixin_44912855 学过 Netty 的都知 ...
- 服务器主动推送消息数据给客户端
1 引言 这个问题第一次是我在实现一个导师的方案的时候所发现的,一开始我需要实现服务器与客户端的密钥协商和数据传递,服务器需要主动分发(推送)密钥给客户端,因为以前没有做过相关编码,后来只能想到用反向 ...
- 关于微信小程序uniapp版的推送消息
1.按钮触发推送消息 <button type="primary" size="mini" @tap="pushMesage"> ...
最新文章
- Python3--爬取海词信息
- mysql与hive2.1.1安装和配置
- ThinkPHP之MVC简析
- 嵌入式之NB-IoT开发与应用01【移动通信网络发展概述、NB-IoT应用案例、物联网生态系统-解决方案、智慧消防项目需求分析及系统设计】
- 小车手app安卓版下载_古筝大师app下载-古筝大师下载v2.1.2 安卓版
- 循环语句与条件语句_在PHP中混合条件语句和循环
- mysql双主双从_mysql双主双从
- 记录一次etcd报错: listen tcp xxx.xxx.xxx.xxx:2380:bind: cannot assign requested address
- BZOJ 1034: [ZJOI2008]泡泡堂BNB
- python怎么打印路径,python 打印路径的几种结果
- 约瑟夫环c语言代码顺序存储,详解约瑟夫环问题及其相关的C语言算法实现
- 3dmax烘焙贴图主要设置之Flatiron
- 富士通Fujitsu DPK2180T 打印机驱动
- https://pypi.tuna.tsinghua.edu.cn/packages/97/ae/0b08f53498417914f2274cc3b5576d2b83179b0cbb209457d0f
- excel条件格式使用详细步骤
- 导入本体到Jena TDB数据库
- c语言函数输出怎么让竖的变横的,c语言里面。为什么我的屏幕输出数字都是竖着输出。而不是横着。怎么才能变成横着。我想输出矩阵格式的。...
- php和durex,做避孕的杜蕾斯突然收购奶粉厂,竟是这样的理由……
- 业界分享 | 京东推荐算法精排技术实践
- finereport与finebi差别_finebi和finereport区别
热门文章
- 大数据分析四大分析要素
- centos 安装mysql5.7
- C语言文件拷贝-四种方式
- 中介者模式php,PHP设计模式之中介者模式
- maven2 clean 错误的解决
- 阿里巴巴战略投资苏宁体育!
- Linux不同发型版本(Debian REHL)与软件包管理器(RPM dpkg)的概念
- linux查看磁盘io的几种方法
- (译)如何使用cocos2d来制作简单的iphone游戏:更猛的怪物和更多的关卡。(第三部分。完!)...
- oracle 10g在redhat4.6上的安装