springboot连接websocket ---超级简单示例
package com.example.rabbitmqdemo.websocket;
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;
import org.springframework.stereotype.Component;
//@Slf4j
@Component
@ServerEndpoint("/info") // 指定websocket 连接的url
public class WebSocketServer {
@OnOpen
public void onOpen(Session session) {
// ("客户端：{}连接成功",());
System.out.println("客户端：{}连接成功"+session.getId());
}
@OnClose
public void onClose(Session session) {
// ("客户端：{}连接断开",());
System.out.println("客户端：{}连接断开"+session.getId());
}
@OnMessage
public String onMsg(String message,Session session) {
// ("从客户端：{} 收到<--:{}", (),message);
System.out.println("从客户端：{} 收到<--:{}"+ session.getId()+message);
String send=message.toUpperCase();
String result="客户：%s您好，来自server 的消息:%s";
result = String.format(result, session.getId(), send);
return "来自server 的消息：" + result;
}
}