guosen-ldt/src/main/java/org/springblade/modules/webSocket/WebSocketController.java

package org.springblade.modules.webSocket;

import com.alibaba.fastjson.JSON;
import io.swagger.annotations.Api;
import lombok.AllArgsConstructor;
import org.springblade.core.tool.api.R;
import org.springblade.modules.webSocket.dto.Message;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

/**
 * @author cy-computer
 */
@RestController
@AllArgsConstructor
@RequestMapping("cyzh-ldt/webSocket")
public class WebSocketController {
	@Resource
	private WebSocketServer webSocketServer;

	@PostMapping("sendInfo")
	public R sendInfo(@RequestBody Message message){
		webSocketServer.sendInfo(message.getSid(),JSON.toJSONString(message,true));
		return R.success("发送成功");
	}
}