002649:websocket的使用及其定义

一、背景

　　1、最近公司要做一个网页上智能收集投诉信息的功能（客户端和小蜜(后台写死的聊天逻辑)聊天的过程收集投诉信息）。 　

　　2、流程：消费者按固定流程输入或选择投诉信息->确认投诉信息->后台生成和解方案->消费者同意/不同意->商家处理待处理的和解信息->消费者查看商家的处理结果。

二、具体分析

　　1、交互的过程则要求前端和后台都能主动发起请求，这有区别于常见的http

　　2、websocket的定义：

　　　　一种在单个TCP连接上进行全双工通信（双向通信）的协议

　　3、概述：

　　　　a、HTML5中提出的 　　　　

　　　　b、相比HTTP： 　　　　　　

　　　　　　b.1、前者一个request一个response,websocket采用的是订阅模式且客户端和服务端都可以想对方推送消息。 　　　　　　

　　　　　　b.2、前者是短连接，每次都是一个请求一个响应，然后就结束了。后者采用的是长连接（一次验证，长期有效），websocket实现消息的转发 　　　　　　

三、实现

　　1、端点信息设置

　　

@Configuration
@EnableWebSocketMessageBroker //启动websocket端点
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

    /**
     * 握手拦截器
     */
    @Autowired
    private WsHandShakeInterceptor wsHandShakeInterceptor;
    /* (non-Javadoc)
     * @see org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer#registerStompEndpoints(org.springframework.web.socket.config.annotation.StompEndpointRegistry)
     */
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry
        .addEndpoint("/ws")//设置端点名称
        .setHandshakeHandler(new MyPrincipalHandshakeHandler()) //设置义用户和websocket的绑定策略，如新用户使用session以及用户的校验，是否登录，返回Principal实现类
        // .setAllowedOrigins("*") // 添加允许跨域访问
        // .setAllowedOrigins("http://mydomain.com");
        .addInterceptors(wsHandShakeInterceptor) // 添加自定义拦截，如握手前设置上下文信息
        .withSockJS(); //withSockJS允许客户端利用sockjs进行浏览器兼容性处理
    }

    /* (non-Javadoc)
     * @see org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer#configureMessageBroker(org.springframework.messaging.simp.config.MessageBrokerRegistry)
     */
    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.setApplicationDestinationPrefixes("/app");//设置客户端订阅消息的基础逻辑，默认也是这个，前端url中提现
        registry.enableSimpleBroker("/topic");   // 设置服务端广播消息的基础路径，默认也是这个，后端提现


        //   Use this for enabling a Full featured broker like RabbitMQ

        /*
        registry.enableStompBrokerRelay("/topic")
                .setRelayHost("localhost")
                .setRelayPort(61613)
                .setClientLogin("guest")
                .setClientPasscode("guest");
        */
    }
｝

　　2、contoller设置

@Controller
public class WebSocketAction {

    private Logger logger = LoggerFactory.getLogger(this.getClass());

    @MessageMapping("/sendTest")
    @SendTo("/topic/subscribeTest") //结果推送客户端，订阅了/topic/subscribeTest的客户端
    public ServerMessage sendDemo(ClientMessage message) {
        logger.info("接收到了信息" + message.getName());
        return new ServerMessage("你发送的消息为:" + message.getName());
    }

    @SubscribeMapping("/subscribeTest")
    public ServerMessage sub() {
        logger.info("XXX用户订阅了我。。。");
        return new ServerMessage("感谢你订阅了我。。。");
    }

}

　　ps:

　　　　1、@MessageMapping(“/sendTest”) 接收客户端发送的信息，发送的url是/app/sendTest（经由消息代理）

　　　　2、@SubscribeMapping(“/subscribeTest”) ，和MessageMapping功能类似，不经由消息代理

　　　　3、@SendTo(“/topic/subscribeTest”)  返回目的地的地址，经由消息代理，所有订阅改路径的客户端都能收到

　　　　4、@SendToUser(value = "/topic/greetings",broadcast = false) 与sendTo功能类似，但只有订阅了改路径的消息发起者能收到信息

　　　　5、SimpMessageSendingOperations.convertAndSend("/topic/public", chatMessage) 等价于@SendTo

　　　　6、@Payload 将消息和对象绑定

参见：

　　http://www.cnblogs.com/jmcui/p/8999998.html