`
wiselyman
  • 浏览: 2093460 次
  • 性别: Icon_minigender_1
  • 来自: 合肥
博客专栏
Group-logo
点睛Spring4.1
浏览量:82289
74ae1471-94c5-3ae2-b227-779326b57435
点睛Spring MVC4...
浏览量:130767
社区版块
存档分类
最新评论

Spring4.0系列9-websocket简单应用

 
阅读更多

Spring4.0系列1-新特性

Spring4.0系列2-环境搭建

Spring4.0系列3-@RestController

Spring4.0系列4-Meta Annotation(元注解)

Spring4.0系列5-@Conditional 

Spring4.0系列6-Generic Qualifier(泛型限定)

Spring4.0系列7-Ordering Autowired Collections

Spring4.0系列8-Groovy DSL

Spring4.0系列9-websocket简单应用

 

Spring 4.0的一个最大更新是增加了websocket的支持。websocket提供了一个在web应用中的高效、双向的通讯,需要考虑到客户端(浏览器)和服务器之间的高频和低延时消息交换。一般的应用场景有:在线交易、游戏、协作、数据可视化等。

 

使用websocket需要考虑的浏览器的支持(IE<10不支持),目前主流的浏览器都能很好的支持websocket。

websocket协议中有一些子协议,可以从更高的层次实现编程模型,就像我们使用HTTP而不是TCP一样。这些子协议有STOMP,WAMP等。

 

本教程只考虑websocket的简单实用,包含Spring对JSR-356的支持及Spring WebSocket API。

1、Java API for WebSocket(JSR-356)

Java API for WebSocket已经是Java EE 7的一部分。它定义了两类endpoit(都是EndPoint类的子类),使用注解标识@ClientEndpoint和@ServerEndpoint。

 

1.1 Servlet容器扫描初始化

通过Spring初始化一个endpoint,只需配置一个SpringConfigurator在类上的@ServerEndpoint注解上。

 

import javax.websocket.server.ServerEndpoint;
import org.springframework.web.socket.server.endpoint.SpringConfigurator;


@ServerEndpoint(value = "/echo", configurator = SpringConfigurator.class);
public class EchoEndpoint {

  private final EchoService echoService;

  @Autowired
  public EchoEndpoint(EchoService echoService) {
    this.echoService = echoService;
  }

  @OnMessage
  public void handleMessage(Session session, String message) {
    // ...
  }

}

 上例假设SpringContextLoaderListener用来加载配置,这是个典型的web应用。Servlet容器将通过扫描@ServerEndpoint和SpringConfigurator初始化一个新的websocket会话。

 1.2 Spring 初始化

如果你想使用一个单独的实例而不使用Servlet容器扫描,将EchoEndpoint类声明称一个bean,并增加一个ServerEndpointExporter的bean:

import org.springframework.web.socket.server.endpoint.ServerEndpointExporter;


@Configuration
public class EndpointConfig {

  @Bean
  public EchoEndpoint echoEndpoint() {
    return new EchoEndpoint(echoService());
  }

  @Bean
  public EchoService echoService() {
    // ...
  }

  @Bean
  public ServerEndpointExporter endpointExporter() {
    return new ServerEndpointExporter();
  }

}

 

 EchoEndpoint 可以通过EndPointRegistration发布:

import org.springframework.web.socket.server.endpoint.ServerEndpointExporter;
import org.springframework.web.socket.server.endpoint.ServerEndpointRegistration;


@Configuration
public class EndpointConfig {

  @Bean
  public EndpointRegistration echoEndpoint() {
    return new EndpointRegistration("/echo", EchoEndpoint.class);
  }

  @Bean
  public ServerEndpointExporter endpointExporter() {
    return new ServerEndpointExporter();
  }

  // ..

}

 本例源码:spring-websocket-test-endpoint.zip

2、Spring WebSocket API

Spring WebSocket API提供了SockJS的支持,且有些容器如Jetty 9目前还没有对JSR-356的支持,所以有Spring WebSocket API是必要的。

 

Spring WebSocket API的核心接口是WebSocketHandler。下面是一个处理文本消息的handler的实现:

import org.springframework.web.socket.adapter.TextWebSocketHandlerAdapter;


public class EchoHandler extends TextWebSocketHandlerAdapter {

  @Override
  public void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
    session.sendMessage(message);
  }

}

 

WebSocketHandler可以通过WebSocketHttpRequestHandler插入到Spring MVC里:

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


@Configuration
public class WebConfig {

  @Bean
  public SimpleUrlHandlerMapping handlerMapping() {

    Map<String, Object> urlMap = new HashMap<String, Object>();
    urlMap.put("/echo", new WebSocketHttpRequestHandler(new EchoHandler()));

    SimpleUrlHandlerMapping hm = new SimpleUrlHandlerMapping();
    hm.setUrlMap(urlMap);
    return hm;
  }

}

 SockJS服务器端的支持

SockJs是一个脚本框架,它提供类似于websocket的编程模式但是可以适应不同的浏览器(包括不支持websocket的浏览器)。

 

开启SockJS的支持,声明一个SockJsService,和一个url映射,然后提供一个WebSocketHandler来处理消息。虽然我们是哟个SockJS我们开发的方式是一样的,但是随着浏览器的不同传输的协议可以是Http Streaming,long polling等。

 

import org.springframework.web.socket.sockjs.SockJsService;
// ...


@Configuration
public class WebConfig {

  @Bean
  public SimpleUrlHandlerMapping handlerMapping() {

    SockJsService sockJsService = new DefaultSockJsService(taskScheduler());

    Map<String, Object> urlMap = new HashMap<String, Object>();
    urlMap.put("/echo/**", new SockJsHttpRequestHandler(sockJsService, new EchoHandler()));

    SimpleUrlHandlerMapping hm = new SimpleUrlHandlerMapping();
    hm.setUrlMap(urlMap);
    return hm;
  }

  @Bean
  public ThreadPoolTaskScheduler taskScheduler() {
    ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
    taskScheduler.setThreadNamePrefix("SockJS-");
    return taskScheduler;
  }

}

 

在我们实际使用中我们会使用WebSocketConfigurer集中注册WebSocket服务:

@Configuration
@EnableWebMvc
@EnableWebSocket//开启websocket
public class WebConfig extends WebMvcConfigurerAdapter implements WebSocketConfigurer {

	@Override
	public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {

		registry.addHandler(echoWebSocketHandler(), "/echo"); //提供符合W3C标准的Websocket数据
		registry.addHandler(snakeWebSocketHandler(), "/snake");

		registry.addHandler(echoWebSocketHandler(), "/sockjs/echo").withSockJS();//提供符合SockJS的数据
		registry.addHandler(snakeWebSocketHandler(), "/sockjs/snake").withSockJS();
	}

	@Bean
	public WebSocketHandler echoWebSocketHandler() {
		return new EchoWebSocketHandler(echoService());
	}

	@Bean
	public WebSocketHandler snakeWebSocketHandler() {
		return new PerConnectionWebSocketHandler(SnakeWebSocketHandler.class);
	}

	@Bean
	public DefaultEchoService echoService() {
		return new DefaultEchoService("Did you say \"%s\"?");
	}

	// Allow serving HTML files through the default Servlet

	@Override
	public void configureDefaultServletHandling(DefaultServletHandlerConfigurer configurer) {
		configurer.enable();
	}

}

  

SockJS客户端代码:

ws = new SockJS(url, undefined, {protocols_whitelist: transports}) ;   //初始化 websocket
         
ws.onopen = function () {
                setConnected(true);
                log('Info: connection opened.');
            };

ws.onmessage = function (event) {
                log('Received: ' + event.data); //处理服务端返回消息
            };

ws.onclose = function (event) {
                setConnected(false);
                log('Info: connection closed.');
                log(event);
            };

 ws.send(message);//向服务端发送消息

 

 程序用maven打成war后用tomcat 8发布查看效果。

本例源码:spring-websocket-test-master.zip

 

新书推荐《JavaEE开发的颠覆者: Spring Boot实战》,涵盖Spring 4.x、Spring MVC 4.x、Spring Boot企业开发实战。

 

京东地址:http://item.jd.com/11894632.html

当当地址:http://product.dangdang.com/23926195.html

亚马逊地址:http://www.amazon.cn/图书/dp/B01D5ZBFUK/ref=zg_bsnr_663834051_6 

淘宝地址:https://item.taobao.com/item.htm?id=528426235744&ns=1&abbucket=8#detail

 

或自己在京东、淘宝、亚马逊、当当、互动出版社搜索自选。

 


分享到:
评论
6 楼 lianghuado 2018-05-31  
 
5 楼 haojie_java_ms 2016-09-27  
感谢!
4 楼 klis_1 2016-04-21  
能用ehcache不?  我是spring3里面整合websocket;
运行正常 ,就是ehcache失效了!
3 楼 sljackson 2015-08-20  
alert('hi');
2 楼 sljackson 2015-08-20  
[u][u]
引用
引用
引用
引用
引用
[/u][/u]
  • [list]
  • [*][list]
  • [*][*][list]
  • [*][*][*][list]
  • [*][*][*][*][list]
  • [*][*][*][*][*][list]
  • [*][*][*][*][*][*][list]
  • [*][*][*][*][*][*][*][list]
  • [*][*][*][*][*][*][*][*][list]
  • [*][*][*][*][*][*][*][*][*][list]
  • [*][*][*][*][*][*][*][*][*][*][list]
  • [*][*][*][*][*][*][*][*][*][*][*][list]
  • [*][*][*][*][*][*][*][*][*][*][*][*]
  • [*][*][*][*][*][*][*][*][*][*][*]
  • [*][*][*][*][*][*][*][*][*][*][/list]
  • [*][*][*][*][*][*][*][*][*][/list]
  • [*][*][*][*][*][*][*][*][/list]
  • [*][*][*][*][*][*][*][/list]
  • [*][*][*][*][*][*][/list]
  • [*][*][*][*][*][/list]
  • [*][*][*][*][/list]
  • [*][*][*][/list]
  • [*][*][/list]
  • [*][/list]
  • [/list]
  • [/list]
    1 楼 hehefan 2014-05-07  
    这个‘本例源码:spring-websocket-test-master.zip’是基于tomcat8.0的maven项目?

    相关推荐

      websocket包spring-websocket-4.0.5.RELEASE,spring-messaging-4.0.5

      Spring Security可以集成到WebSocket应用中,提供这些安全保障。 9. **WebSocket的应用场景**: WebSocket适用于需要实时交互的场景,如实时聊天、在线协作工具、股票行情推送、多人在线游戏等。利用Spring提供的...

      spring4.0完整jar包

      在下载的"spring4.0完整jar"中,通常会包含这些核心模块和其他相关模块的jar文件,如Spring Aspects、Spring Context、Spring Expression Language (SpEL)等。这些jar文件是构建基于Spring的应用的基础,确保了所有...

      grails-spring-websocket

      该插件旨在使Spring 4.0中引入的websocket支持可用于Grails应用程序。 您也可以使用相应的Spring docs / apis / samples作为参考。 在本自述文件中多次提到了这一点,因为其中详细解释了所有内容。 Grails版本...

      spring4.0框架demo

      2. WebSocket支持:Spring 4.0引入了对WebSocket协议的支持,提供了更高效、实时的通信机制,为Web应用带来了新的交互体验。 3. 改进的类型安全:在Spring 4.0中,依赖注入(DI)更加类型安全,降低了因配置错误...

      spring-websocket-test-master.zip

      Spring提供了`WebSocketMessageBrokerStatsHandler`,可以收集WebSocket的统计信息,帮助开发者监控和调试WebSocket应用。 总结,Spring集成WebSocket提供了强大的实时通讯能力,结合STOMP协议,可以轻松构建高效、...

      Spring4.0 jar包

      9. **消息支持**:Spring4.0增强了对消息传递系统的支持,特别是JMS(Java Message Service),为异步处理和解耦提供了强大工具。 10. **模块化设计**:Spring4.0的模块化设计使得开发者可以根据项目需求选择需要的...

      spring4.0 jar包

      2. **WebSocket支持**:Spring 4.0添加了对WebSocket协议的全面支持,通过`spring-messaging`模块,开发者可以方便地创建基于WebSocket的应用,实现双向通信,提高实时性。 3. **响应式编程**:虽然Spring 4.0没有...

      spring4.0 websocket简单应用.docx

      总结:Spring 4.0 的 WebSocket 支持使得开发高效、实时的 Web 应用变得更加便捷。结合 Java API for WebSocket (JSR-356) 和 Spring WebSocket API,开发者可以构建出复杂且健壮的实时通信应用,覆盖在线交易、游戏...

      spring-framework-4.0.3.RELEASE-dist.zip

      Spring Framework 4.0系列是Spring的重要里程碑,它标志着Spring进入了Java 8和WebSocket的支持时代。4.0.3.RELEASE作为4.0系列的一个重要维护版本,其主要关注点在于修复已知问题、提升性能以及对现有功能的优化。 ...

      Spring 4.0 API

      8. **WebSocket支持**:Spring 4.0 添加了对WebSocket协议的支持,为实时通信提供了基础,可用于构建聊天应用、股票报价等实时更新的应用场景。 9. **类型安全的转换服务**:Spring 4.0 提供了Type-Safe Conversion...

      官方 Spring4.0 jar包

      5. **WebSocket支持**:Spring 4.0引入了对WebSocket协议的全面支持,通过WebSocketTemplate和SockJS技术,实现了服务器与客户端的双向通信,为实时应用提供了强大的基础。 6. **Java 8兼容**:Spring 4.0开始支持...

      spring4.0 全部jar包 spring4.0

      Spring 4.0作为其一个重要版本,引入了许多改进和新特性,旨在提升开发效率和应用程序性能。下面将详细介绍Spring 4.0中的关键知识点。 1. **模块化结构**: Spring 4.0对原有的模块进行了重构,使其更加独立,...

      Spring4.0源代码

      7. **WebSocket支持**:Spring4.0引入了WebSocket支持,提供了`@ServerEndpoint`和`@ClientEndpoint`注解,使得开发实时通信应用变得简单。 8. **JDBC增强**:Spring4.0的JdbcTemplate和NamedParameterJdbcTemplate...

      spring 4.0.x源码

      2. **WebSocket支持**:Spring 4引入了对WebSocket协议的支持,通过WebSocket API和JSR 356(Java API for WebSocket),开发人员可以创建实时双向通信的应用,实现服务器与客户端的高效交互,这对于构建富互联网...

      SPRING 4.0 中文指南

      Spring框架是Java开发中的核心组件,它为构建高质量、可维护和可测试的Java应用程序提供了强大的支持。Spring 4.0版本是该框架的一个重要里程碑,引入了许多改进和新特性,使得开发者能够更加高效地工作。这篇指南将...

    Global site tag (gtag.js) - Google Analytics