WebSocketTestController.java

//package com.testor.websocket;
//
//import com.tongtech.tfw.backend.common.biz.models.BaseResponse;
//import io.swagger.annotations.Api;
//import io.swagger.annotations.ApiOperation;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.web.bind.annotation.GetMapping;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
//
//import javax.annotation.Resource;
//import java.util.ArrayList;
//import java.util.Date;
//import java.util.List;
//
//@RestController
//@RequestMapping("/websocket/test")
//@Api(value = "websocketTest", tags = "websocket测试")
//@Slf4j
//public class WebSocketTestController {
//
//    @Resource
//    private WebSocketServer webSocketServer;
//
//    @ApiOperation(value = "测试发送一条消息 ", notes = "detail TSysNotice By Id")
//    @GetMapping(value = "/sendOne")
//    public BaseResponse sendOne(){
//        Message messageObj = new Message();
//        messageObj.setFrom("ddd");
//        messageObj.setTo("1242684364872761344");
//        messageObj.setMsg("sj测试发送消息-内容");
//        messageObj.setType("1");
//        messageObj.setSendTime(new Date());
//        webSocketServer.sendTextMessage(messageObj);
//        return new BaseResponse();
//    }
//
//    @ApiOperation(value = "测试一次发送多条消息 ", notes = "detail TSysNotice By Id")
//    @GetMapping(value = "/sendByList")
//    public BaseResponse sendByList(){
//        List<String> msgList = new ArrayList();
//        msgList.add("第一条消息");
//        msgList.add("第二条消息");
//        msgList.add("第三条消息");
//        Message<List> messageObj = new Message();
//        messageObj.setFrom("ddd");
//        messageObj.setTo("1242684364872761344");
//        messageObj.setMsg(msgList);
//        messageObj.setType("1");
//        messageObj.setSendTime(new Date());
//        webSocketServer.sendTextMessage(messageObj);
//        return new BaseResponse();
//    }
//}
//