springmvc代理请求(springmvc是怎样接受websocket请求的)
本文目录
springmvc是怎样接受websocket请求的
***隐藏网址***1.客户端请求一个链接,头部中包含如下信息GET /demo HTTP/1.1Host: example.comConnection: UpgradeSec-WebSocket-Key2: 12998 5 Y3 1 .P00Upgrade: WebSocketSec-WebSocket-Key1: 4@1 46546xW%0l 1 5***隐藏网址***2.服务器根据头部中的Sec-WebSocket-Key2,Sec-WebSocket-Key1,Upgrade, 知道客户端需要一个websocket协议链接,于是返回一个消息,包含如下头部HTTP/1.1 101 WebSocket Protocol HandshakeUpgrade: WebSocketConnection: Upgrade***隐藏网址***WebSocket-Location: ws://example.com/demo3.客户端收到消息之后,建立起websocket链接,这时就可以进行实时通信了我们可以定义一个处理器来实现WebSocketHandler处理请求public class MyWebSocketHandler implements WebSocketHandler{/*** webscoket建立好链接之后的处理函数* @param session 当前websocket的会话id,打开一个websocket通过都会生成唯一的一个会话,可以通过该id进行发送消息到浏览器客户端*/@Overridepublic void afterConnectionEstablished(WebSocketSession session) throws Exception {// TODO Auto-generated method stub}/*** 客户端发送服务器的消息时,的处理函数,在这里收到消息之后可以分发消息*/@Overridepublic void handleMessage(WebSocketSession session, WebSocketMessage《?》 message) throws Exception {// TODO Auto-generated method stub}/*** 消息传输过程中出现的异常处理函数*/@Overridepublic void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {// TODO Auto-generated method stub}/*** websocket链接关闭的回调*/@Overridepublic void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {// TODO Auto-generated method stub}/*** 是否支持处理拆分消息,返回true返回拆分消息*/@Overridepublic boolean supportsPartialMessages() {// TODO Auto-generated method stubreturn false;}}***隐藏网址***public class MyHandShakeInterceptor implements HandshakeInterceptor{/*** 握手之前,若返回false,则不建立链接*/@Overridepublic boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler,Map《String, Object》 attributes) throws Exception {// TODO Auto-generated method stubreturn true;}/*** 握手之后*/@Overridepublic void afterHandshake(ServerHttpRequest requestscjgcj.comServerHttpResponse response, WebSocketHandler wsHandler,Exception exception) {// TODO Auto-generated method stub}}接下来,需要我们把处理器和拦截器注册到spring websocket中@Configuration@EnableWebSocketpublic class WebSocketConfig implements WebSocketConfigurer {@Overridepublic void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {registry.addHandler(new MyWebSocketHandler(), "/portfolio")//添加一个处理器还有定义处理器的处理路径.addInterceptors(new MyHandShakeInterceptor()).withSockJS();}}在这里我们用到.withSockJS(),SockJS是spring用来处理浏览器对websocket的兼容性,目前浏览器支持websocket还不是很好,特别是IE11以下.SockJS能关键浏览器能否支持websocket来提供三种方式用于websocket请求,三种方式分别是 WebSocket, HTTP Streaming以及 HTTP Long PollingSockJS提供了浏览器客户端的js库,在浏览器我们请求websocket就这么用var socket = new SockJS(’/whats/portfolio’);//项目名称 + 处理器拦截路径名就会打开的目的websocket链接口/*** 建立成功的回调函数*/socket.onopen = function() {console.log(’open’);};/*** 服务器有消息返回的回调函数*/socket.onmessage = function(e) {console.log(’message’, e.data);};/*** websocket链接关闭的回调函数*/socket.onclose = function() {console.log(’close’);};然后客户端发送一个消息document.getElementById("ws").onclick = function() {socket.send("fff");}服务器MyWebSocketHandler中,通过handlemessage接收消息并进行分发/*** 客户端发送服务器的消息时,的处理函数,在这里收到消息之后可以分发消息*/@Overridepublic void handleMessage(WebSocketSession session, WebSocketMessage《?》 message) throws Exception {//获取消息String body = (String) message.getPayload();//一系列的处理之后...//发送消息session.sendMessage(message);}***隐藏网址***首先在自定义的处理其中,建一个队列来存储连进来的websocketsessionpublic class MyWebSocketHandler implements WebSocketHandler{private List《WebSocketSession》 users = new ArrayList《WebSocketSession》(); //存放WebSocketSession的队列/*** webscoket建立好链接之后的处理函数* @param session 当前websocket的会话id,打开一个websocket通过都会生成唯一的一个会话,可以通过该id进行发送消息到浏览器客户端*/@Overridepublic void afterConnectionEstablished(WebSocketSession session) throws Exception {session.getAttributes().put("userid", "xxxx");//如果有用户登录,可以把用户的id绑定到session里面,便于后面做精准推送users.add(session); //每个链接来的客户端都把WebSocketSession保存进来}//...}然后呢,我们在接收到消息的时候,就可以直接的根据需要精准推送到用户或者全部推送了/*** 客户端发送服务器的消息时,的处理函数,在这里收到消息之后可以分发消息*/@Overridepublic void handleMessage(WebSocketSession session, WebSocketMessage《?》 message) throws Exception {// TODO Auto-generated method stubfor (WebSocketSession webSocketSession : users) {//Long id = (Long) session.getAttributes().get("userid");//可以通过获取userid进行匹配,从而进行精准推送message = new TextMessage("ggg");webSocketSession.sendMessage(message); //全部推送}}spring websocket大概的请求过程就是这样子,这是基础的请求过程,细心的同学可能发现,如果我有很多种不同的业务请求,是不是要写很多个处理器??能不能只实现一个处理器,然后由这个处理器来进行分发处理,做到类似springmvc的DispatcherServlet那样子??下次研究看看
springmvc 请求头和请求体 有什么用
1. Content-Type MediaType,即是Internet Media Type,互联网媒体类型;也叫做MIME类型,在Http协议消息头中,使用Content-Type来表示具体请求中的媒体类型信息。 view plain copy 类型格式:type/subtype(;parameter)? type 主类型,任意的字符串,如text,如果是*号代表所有; subtype 子类型,任意的字符串,如html,如果是*号代表所有; parameter 可选,一些参数,如Accept请求头的q参数, Content-Type的 charset参数。 例如: Content-Type: text/html;charset:utf-8; 常见的媒体格式类型如下: text/html : HTML格式 text/plain :纯文本格式 text/xml : XML格式 image/gif :gif图片格式 image/jpeg :jpg图片格式 image/png:png图片格式 以application开头的媒体格式类型: application/xhtml+xml :XHTML格式 application/xml : XML数据格式 application/atom+xml :Atom XML聚合格式 application/json : JSON数据格式 application/pdf :pdf格式 application/msword : Word文档格式 application/octet-stream : 二进制流数据(如常见的文件下载) application/x-www-form-urlencoded : 《form encType=””》中默认的encType,form表单数据被编码为key/value格式发送到服务器(表单默认的提交数据的格式) 另外一种常见的媒体格式是上传文件之时使用的: multipart/form-data : 需要在表单中进行文件上传时,就需要使用该格式 以上就是我们在日常的开发中,经常会用到的若干content-type的内容格式。2. Spring MVC中关于关于Content-Type类型信息的使用 首先我们来看看RequestMapping中的Class定义: view plain copy @Target({ElementType.METHOD, ElementType.TYPE}) @Retention(RetentionPolicy.RUNTIME) @Documented @Mapping public @interface RequestMapping { String value() default {}; RequestMethod method() default {}; String params() default {}; String headers() default {}; String consumes() default {}; String produces() default {}; } value: 指定请求的实际地址, 比如 /action/info之类。method: 指定请求的method类型, GET、POST、PUT、DELETE等consumes: 指定处理请求的提交内容类型(Content-Type),例如application/json, text/html;produces: 指定返回的内容类型,仅当request请求头中的(Accept)类型中包含该指定类型才返回params: 指定request中必须包含某些参数值是,才让该方法处理headers: 指定request中必须包含某些指定的header值,才能让该方法处理请求其中,consumes, produces使用content-typ信息进行过滤信息;headers中可以使用content-type进行过滤和判断。3. 使用示例 3.1 headers view plain copy ***隐藏网址***public void testHeaders(@PathVariable String ownerId, @PathVariable String petId) { // implementation omitted } 这里的Headers里面可以匹配所有Header里面可以出现的信息,不局限在Referer信息。 示例2 view plain copy @RequestMapping(value = "/response/ContentType", headers = "Accept=application/json") public void response2(HttpServletResponse response) throws IOException { //表示响应的内容区数据的媒体类型为json格式,且编码为utf-8(客户端应该以utf-8解码) response.setContentType("application/json;charset=utf-8"); //写出响应体内容 String jsonData = "{\"username\":\"zhang\", \"password\":\"123\"}"; response.getWriter().write(jsonData); } 服务器根据请求头“Accept=application/json”生产json数据。当你有如下Accept头,将遵守如下规则进行应用:①Accept:text/html,application/xml,application/json 将按照如下顺序进行produces的匹配 ①text/html ②application/xml ③application/json②Accept:application/xml;q=0.5,application/json;q=0.9,text/html 将按照如下顺序进行produces的匹配 ①text/html ②application/json ③application/xml 参数为媒体类型的质量因子,越大则优先权越高(从0到1)③Accept:*/*,text/*,text/html 将按照如下顺序进行produces的匹配 ①text/html ②text/* ③*/*即匹配规则为:最明确的优先匹配。Requests部分Header解释示例Accept 指定客户端能够接收的内容类型 Accept: text/plain, text/html Accept-Charset 浏览器可以接受的字符编码集。 Accept-Charset: iso-8859-5 Accept-Encoding 指定浏览器可以支持的web服务器返回内容压缩编码类型。 Accept-Encoding: compress, gzip Accept-Language 浏览器可接受的语言 Accept-Language: en,zh Accept-Ranges 可以请求网页实体的一个或者多个子范围字段 Accept-Ranges: bytes Authorization HTTP授权的授权证书 Authorization: Basic QWxhZGRpbjpvcGVuIHNlc2FtZQ== Cache-Control 指定请求和响应遵循的缓存机制 Cache-Control: no-cache Connection 表示是否需要持久连接。(HTTP 1.1默认进行持久连接) Connection: close Cookie HTTP请求发送时,会把保存在该请求域名下的所有cookie值一起发送给web服务器。 Cookie: $Version=1; Skin=new; Content-Length 请求的内容长度 Content-Length: 348 Content-Type 请求的与实体对应的MIME信息 Content-Type: application/x-www-form-urlencoded Date 请求发送的日期和时间 Date: Tue, 15 Nov 2010 08:12:31 GMT Expect 请求的特定的服务器行为 Expect: 100-continue From 发出请求的用户的Email From: user@email.com Host 指定请求的服务器的域名和端口号 Host: www.zcmhi.com If-Match 只有请求内容与实体相匹配才有效 If-Match: “737060cd8c284d8af7ad3082f209582d” If-Modified-Since 如果请求的部分在指定时间之后被修改则请求成功,未被修改则返回304代码 If-Modified-Since: Sat, 29 Oct 2010 19:43:31 GMT If-None-Match 如果内容未改变返回304代码,参数为服务器先前发送的Etag,与服务器回应的Etag比较判断是否改变 If-None-Match: “737060cd8c284d8af7ad3082f209582d” If-Range 如果实体未改变,服务器发送客户端丢失的部分,否则发送整个实体。参数也为Etag If-Range: “737060cd8c284d8af7ad3082f209582d” If-Unmodified-Since 只在实体在指定时间之后未被修改才请求成功 If-Unmodified-Since: Sat, 29 Oct 2010 19:43:31 GMT Max-Forwards 限制信息通过代理和网关传送的时间 Max-Forwards: 10 Pragma 用来包含实现特定的指令 Pragma: no-cache Proxy-Authorization 连接到代理的授权证书 Proxy-Authorization: Basic QWxhZGRpbjpvcGVuIHNlc2FtZQ== Range 只请求实体的一部分,指定范围 Range: bytes=500-999 ***隐藏网址***TE 客户端愿意接受的传输编码,并通知服务器接受接受尾加头信息 TE: trailers,deflate;q=0.5 Upgrade 向服务器指定某种传输协议以便服务器进行转换(如果支持) Upgrade: HTTP/2.0, SHTTP/1.3, IRC/6.9, RTA/x11 User-Agent User-Agent的内容包含发出请求的用户信息 User-Agent: Mozilla/5.0 (Linux; X11) Via 通知中间网关或代理服务器地址,通信协议 Via: 1.0 fred, 1.1 nowhere.com (Apache/1.1) Warning 关于消息实体的警告信息 Warn: 199 Miscellaneous warning Responses 部分 Header解释示例Accept-Ranges 表明服务器是否支持指定范围请求及哪种类型的分段请求 Accept-Ranges: bytes Age 从原始服务器到代理缓存形成的估算时间(以秒计,非负) Age: 12 Allow 对某网络资源的有效的请求行为,不允许则返回405 Allow: GET, HEAD Cache-Control 告诉所有的缓存机制是否可以缓存及哪种类型 Cache-Control: no-cache Content-Encoding web服务器支持的返回内容压缩编码类型。 Content-Encoding: gzip Content-Language 响应体的语言 Content-Language: en,zh Content-Length 响应体的长度 Content-Length: 348 Content-Location 请求资源可替代的备用的另一地址 Content-Location: /index.htm Content-MD5 返回资源的MD5校验值 Content-MD5: Q2hlY2sgSW50ZWdyaXR5IQ== Content-Range 在整个返回体中本部分的字节位置 Content-Range: bytes 21010-47021/47022 Content-Type 返回内容的MIME类型 Content-Type: text/html; charset=utf-8 Date 原始服务器消息发出的时间 Date: Tue, 15 Nov 2010 08:12:31 GMT ETag 请求变量的实体标签的当前值 ETag: “737060cd8c284d8af7ad3082f209582d” Expires 响应过期的日期和时间 Expires: Thu, 01 Dec 2010 16:00:00 GMT Last-Modified 请求资源的最后修改时间 Last-Modified: Tue, 15 Nov 2010 12:45:26 GMT ***隐藏网址***Pragma 包括实现特定的指令,它可应用到响应链上的任何接收方 Pragma: no-cache Proxy-Authenticate 它指出认证方案和可应用到代理的该URL上的参数 Proxy-Authenticate: Basic refresh 应用于重定向或一个新的资源被创造,在5秒之后重定向(由网景提出,被大部分浏览器支持) Refresh: 5; url=***隐藏网址***Retry-After 如果实体暂时不可取,通知客户端在指定时间之后再次尝试 Retry-After: 120 Server web服务器软件名称 Server: Apache/1.3.27 (Unix) (Red-Hat/Linux) Set-Cookie 设置Http Cookie Set-Cookie: UserID=JohnDoe; Max-Age=3600; Version=1 Trailer 指出头域在分块传输编码的尾部存在 Trailer: Max-Forwards Transfer-Encoding 文件传输编码 Transfer-Encoding:chunked Vary 告诉下游代理是使用缓存响应还是从原始服务器请求 Vary: * Via 告知代理客户端响应是通过哪里发送的 Via: 1.0 fred, 1.1 nowhere.com (Apache/1.1) Warning 警告实体可能存在的问题 Warning: 199 Miscellaneous warning WWW-Authenticate 表明客户端请求实体应该使用的授权方案 WWW-Authenticate: Basic 3.2 params的示例 view plain copy @RequestMapping(value = "/test/{userId}", method = RequestMethod.GET, params="myParam=myValue") public void findUser(@PathVariable String userId) { // implementation omitted } 仅处理请求中包含了名为“myParam”,值为“myValue”的请求,起到了一个过滤的作用。3.3 consumes/produces view plain copy @Controller @RequestMapping(value = "/users", method = RequestMethod.POST, consumes="application/json", produces="application/json") @ResponseBody public List《User》 addUser(@RequestBody User userl) { // implementation omitted return List《User》 users; } 方法仅处理request Content-Type为“application/json”类型的请求. produces标识==》处理request请求中Accept头中包含了"application/json"的请求,同时暗示了返回的内容类型为application/json;4. 总结 在本文中,首先介绍了Content-Type主要支持的格式内容,然后基于@RequestMapping标注的内容介绍了主要的使用方法,其中,headers, consumes,produces,都是使用Content-Type中使用的各种媒体格式内容,可以基于这个格式内容来进行访问的控制和过滤。
更多文章:
怎样在我自己做的购物网站中链接到支付宝付款?我是做外贸的,现在B2C购物网站搭建哪家好
2024年7月15日 12:11
传奇世界手游新开服网站(传奇世界3d手游2022年12月8日新区开服时间)
2024年7月28日 20:11
合成大西瓜ios(《合成大西瓜》可以合成两个西瓜吗两个西瓜会合成什么样)
2024年5月17日 07:24
微信在另一台设备上登录(怎样在另一个手机上登录同一个微信号)
2024年7月13日 03:40
cad建筑图纸免费下载(建筑CAD图纸免费下载网址古代建筑详细介绍)
2024年7月17日 22:00
帝国ol为什么停服?帝国OL全面战争闪退黑屏游戏进不去怎么办
2024年2月17日 19:20
文山教育信息网(实小东校区2022年什么时候开始招生文山市)
2024年5月4日 09:04
proteus元件库对照表(7段共阴数码管怎样能在proteus里找到)
2024年8月1日 06:26
cad迷你看图下载(cad看图软件,去哪里下载,求大家给我个网址)
2024年5月31日 12:35
教你盗wifi密码(手机万能钥匙怎么破解别人家的WiFi密码)
2024年7月17日 13:15
你在办公室见过最荒唐的事是什么?你在工作中做过的最疯狂的事情是什么
2024年6月23日 21:48
我的e家客户端(为什么星空极速或者我的e家客户端运行较长时间后没有升级提示)
2024年6月10日 05:10