✨ cron 生成组件.
This commit is contained in:
@@ -8,7 +8,7 @@
|
||||
:cancel-button-props="{ disabled: loading }"
|
||||
:on-before-ok="handlerOk"
|
||||
@cancel="handleClose">
|
||||
<a-spin class="full modal-form-small" :loading="loading">
|
||||
<a-spin class="full drawer-form-small" :loading="loading">
|
||||
<a-form :model="formModel"
|
||||
ref="formRef"
|
||||
label-align="right"
|
||||
|
||||
@@ -94,8 +94,10 @@ public class WebSocketSyncSession implements WebSocketSession {
|
||||
}
|
||||
|
||||
@Override
|
||||
public synchronized void sendMessage(WebSocketMessage<?> message) throws IOException {
|
||||
this.delegate.sendMessage(message);
|
||||
public void sendMessage(WebSocketMessage<?> message) throws IOException {
|
||||
synchronized (this.delegate) {
|
||||
this.delegate.sendMessage(message);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
@@ -70,8 +70,15 @@ public class WebSockets {
|
||||
return;
|
||||
}
|
||||
try {
|
||||
// 发送消息
|
||||
session.sendMessage(new TextMessage(message));
|
||||
if (session instanceof WebSocketSyncSession) {
|
||||
// 发送消息
|
||||
session.sendMessage(new TextMessage(message));
|
||||
} else {
|
||||
synchronized (session) {
|
||||
// 发送消息
|
||||
session.sendMessage(new TextMessage(message));
|
||||
}
|
||||
}
|
||||
} catch (IllegalStateException e) {
|
||||
// 并发异常
|
||||
log.error("发送消息失败, 准备进行重试 {}", Exceptions.getDigest(e));
|
||||
|
||||
Reference in New Issue
Block a user