qq27800734/taoyao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[*] 配置平台

Browse Source
This commit is contained in:
acgist
2022-11-20 09:29:23 +08:00
parent f6c6674113
commit b1c7bf2601
4 changed files with 25 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
taoyao-signal/src/main/java/com/acgist/taoyao/signal/config/SignalAutoConfiguration.java
View File

@@ -1,12 +1,16 @@
package com.acgist.taoyao.signal.config; package com.acgist.taoyao.signal.config;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.config.annotation.EnableWebSocket; import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.server.standard.ServerEndpointExporter; import org.springframework.web.socket.server.standard.ServerEndpointExporter;
import com.acgist.taoyao.signal.client.websocket.WebSocketSignal; import com.acgist.taoyao.signal.client.websocket.WebSocketSignal;
import com.acgist.taoyao.signal.listener.platform.ScriptListener;
import com.acgist.taoyao.signal.protocol.platform.ScriptProtocol;
import com.acgist.taoyao.signal.protocol.platform.ShutdownProtocol;
/** /**
* 信令配置 * 信令配置
@@ -29,4 +33,25 @@ public class SignalAutoConfiguration {
return new ServerEndpointExporter(); return new ServerEndpointExporter();
} }
@Bean
@ConditionalOnProperty(prefix = "taoyao.signal.platform.script", name = "enabled", havingValue = "true", matchIfMissing = true)
@ConditionalOnMissingBean
public ScriptProtocol scriptProtocol() {
return new ScriptProtocol();
}
@Bean
@ConditionalOnProperty(prefix = "taoyao.signal.platform.script", name = "enabled", havingValue = "true", matchIfMissing = true)
@ConditionalOnMissingBean
public ScriptListener scriptListener() {
return new ScriptListener();
}
@Bean
@ConditionalOnProperty(prefix = "taoyao.signal.platform.shutdown", name = "enabled", havingValue = "true", matchIfMissing = true)
@ConditionalOnMissingBean
public ShutdownProtocol shutdownProtocol() {
return new ShutdownProtocol();
}
} }

2
taoyao-signal/src/main/java/com/acgist/taoyao/signal/listener/platform/ScriptListener.java
View File

@@ -5,7 +5,6 @@ import java.util.Map;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import com.acgist.taoyao.boot.model.Message; import com.acgist.taoyao.boot.model.Message;
import com.acgist.taoyao.signal.client.ClientSession; import com.acgist.taoyao.signal.client.ClientSession;
@@ -20,7 +19,6 @@ import lombok.extern.slf4j.Slf4j;
* @author acgist * @author acgist
*/ */
@Slf4j @Slf4j
@Component
public class ScriptListener extends ApplicationListenerAdapter<ScriptEvent> { public class ScriptListener extends ApplicationListenerAdapter<ScriptEvent> {
@Async @Async

3
taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/platform/ScriptProtocol.java
View File

@@ -2,8 +2,6 @@ package com.acgist.taoyao.signal.protocol.platform;
import java.util.Map; import java.util.Map;
import org.springframework.stereotype.Component;
import com.acgist.taoyao.boot.model.Message; import com.acgist.taoyao.boot.model.Message;
import com.acgist.taoyao.signal.client.ClientSession; import com.acgist.taoyao.signal.client.ClientSession;
import com.acgist.taoyao.signal.event.platform.ScriptEvent; import com.acgist.taoyao.signal.event.platform.ScriptEvent;
@@ -14,7 +12,6 @@ import com.acgist.taoyao.signal.protocol.ProtocolMapAdapter;
* *
* @author acgist * @author acgist
*/ */
@Component
public class ScriptProtocol extends ProtocolMapAdapter { public class ScriptProtocol extends ProtocolMapAdapter {
public static final Integer PID = 1001; public static final Integer PID = 1001;

2
taoyao-signal/src/main/java/com/acgist/taoyao/signal/protocol/platform/ShutdownProtocol.java
View File

@@ -1,7 +1,6 @@
package com.acgist.taoyao.signal.protocol.platform; package com.acgist.taoyao.signal.protocol.platform;
import org.springframework.context.ConfigurableApplicationContext; import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.stereotype.Component;
import com.acgist.taoyao.boot.model.Message; import com.acgist.taoyao.boot.model.Message;
import com.acgist.taoyao.signal.client.ClientSession; import com.acgist.taoyao.signal.client.ClientSession;
@@ -15,7 +14,6 @@ import lombok.extern.slf4j.Slf4j;
* @author acgist * @author acgist
*/ */
@Slf4j @Slf4j
@Component
public class ShutdownProtocol extends ProtocolAdapter { public class ShutdownProtocol extends ProtocolAdapter {
public static final Integer PID = 1000; public static final Integer PID = 1000;