| | |
|---|
| | | package com.ruoyi.system.websocket; |
|---|
| | | |
|---|
| | | import com.ruoyi.system.api.util.WebSocketUsers_Bak; |
|---|
| | | import java.util.concurrent.Semaphore; |
|---|
| | | import javax.websocket.OnClose; |
|---|
| | | import javax.websocket.OnError; |
|---|
| | | import javax.websocket.OnMessage; |
|---|
| | | import javax.websocket.OnOpen; |
|---|
| | | import javax.websocket.Session; |
|---|
| | | import javax.websocket.server.ServerEndpoint; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import org.slf4j.LoggerFactory; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * websocket 消息处理 |
|---|
| | | * |
|---|
| | | * @author ruoyi |
|---|
| | | */ |
|---|
| | | @Component |
|---|
| | | @ServerEndpoint("/websocket/message") |
|---|
| | | // @Component |
|---|
| | | // @ServerEndpoint("/websocket/message") |
|---|
| | | public class WebSocketServer_Bak { |
|---|
| | | |
|---|
| | | /** |
|---|
