| | |
|---|
| | | import com.java110.utils.util.StringUtil; |
|---|
| | | import com.java110.vo.ResultVo; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import org.slf4j.LoggerFactory; |
|---|
| | | import com.java110.core.log.LoggerFactory; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | |
|---|
| | | import javax.websocket.*; |
|---|
| | |
|---|
| | | * 实现服务器主动推送 |
|---|
| | | */ |
|---|
| | | public void sendMessage(String message) throws IOException { |
|---|
| | | this.session.getBasicRemote().sendText(message); |
|---|
| | | // this.session.getBasicRemote().sendText(message); |
|---|
| | | synchronized (this.session) { |
|---|
| | | this.session.getBasicRemote().sendText(message); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
