| | |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.concurrent.ConcurrentHashMap; |
|---|
| | | |
|---|
| | | import org.apache.catalina.core.ApplicationContext; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import org.slf4j.LoggerFactory; |
|---|
| | | |
|---|
| | |
|---|
| | | */ |
|---|
| | | public void sendMessage(String message) { |
|---|
| | | try { |
|---|
| | | log.info("服务端给客户端[{}]发送消息{}", this.session.getId(), message); |
|---|
| | | // log.info("服务端给客户端[{}]发送消息{}", this.session.getId(), message); |
|---|
| | | this.session.getBasicRemote().sendText(message); |
|---|
| | | } catch (Exception e) { |
|---|
| | | log.error("服务端发送消息给客户端失败", e); |
|---|
| | |
|---|
| | | public void sendAllMessage(String message) { |
|---|
| | | try { |
|---|
| | | for (WebSocketServer webSocketServer : sessionMap.values()) { |
|---|
| | | log.info("服务端给客户端[{}]发送消息{}", this.session.getId(), message); |
|---|
| | | //log.info("服务端给客户端[{}]发送消息{}", this.session.getId(), message); |
|---|
| | | webSocketServer.sendMessage(message); |
|---|
| | | } |
|---|
| | | } catch (Exception e) { |
|---|
