[管理]CommandsOnStarted——开服运行指令[1.10] - 服务端插件

GiNYAi

本帖最后由 GiNYAi 于 2018-2-25 15:44 编辑
开服运行指令

一个简单的小插件
总觉得名字起的有点奇怪
在服务器开启之后执行命令支持延迟和重复执行
基于SpongeAPI 5.1 并不保证能在其它版本正常运行
如果无法正常运行，并且你有需要，可以回帖告诉我
下载

CommandsOnStarted-1.0-SNAPSHOT.jar (8.33 KB, 下载次数: 118)
安装

放入mods文件夹
命令

没有命令，不支持使用/sponge plugins reload 重载
配置文件

源代码

package net.ginyai.commandsonstarted;
import com.google.common.reflect.TypeToken;
import com.google.inject.Inject;
import ninja.leaping.configurate.ConfigurationNode;
import ninja.leaping.configurate.ConfigurationOptions;
import ninja.leaping.configurate.commented.CommentedConfigurationNode;
import ninja.leaping.configurate.hocon.HoconConfigurationLoader;
import ninja.leaping.configurate.loader.ConfigurationLoader;
import ninja.leaping.configurate.objectmapping.ObjectMappingException;
import ninja.leaping.configurate.objectmapping.serialize.TypeSerializer;
import ninja.leaping.configurate.objectmapping.serialize.TypeSerializerCollection;
import ninja.leaping.configurate.objectmapping.serialize.TypeSerializers;
import org.slf4j.Logger;
import org.spongepowered.api.Sponge;
import org.spongepowered.api.command.CommandSource;
import org.spongepowered.api.config.ConfigDir;
import org.spongepowered.api.entity.living.player.Player;
import org.spongepowered.api.event.Listener;
import org.spongepowered.api.event.Order;
import org.spongepowered.api.event.filter.Getter;
import org.spongepowered.api.event.game.GameReloadEvent;
import org.spongepowered.api.event.game.state.GamePreInitializationEvent;
import org.spongepowered.api.event.game.state.GameStartedServerEvent;
import org.spongepowered.api.event.network.ClientConnectionEvent;
import org.spongepowered.api.plugin.Plugin;
import org.spongepowered.api.scheduler.Task;
import org.spongepowered.api.text.Text;
import org.spongepowered.api.text.format.TextColors;
import org.spongepowered.api.text.format.TextStyles;
import java.io.IOException;
import java.nio.file.Path;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
@Plugin(
id = "commandsonstarted",
name = "CommandsOnStarted",
authors = {
"GiNYAi"
},
description = "Run commands after server started.",
version = "1.0.0"
)
public class CommandsOnStarted {
@Inject
private Logger logger;
@Inject@ConfigDir(sharedRoot = true)
private Path configDir;
private List<CommandGroup> commandGroups = new ArrayList<>();
@Listener
public void onPreInit(GamePreInitializationEvent event) {
try {
load();
} catch (IOException e) {
logger.error("Failed to load config.",e);
}
}
@Listener(order = Order.POST)
public void onServerStarted(GameStartedServerEvent event){
commandGroups.forEach(CommandGroup::process);
}
private void load() throws IOException {
Path configPath = configDir.resolve("CommandsOnStarted.conf");
if(!configPath.toFile().exists()){
Sponge.getAssetManager().getAsset(this,"default_config.conf").get().copyToFile(configPath);
}
ConfigurationLoader<CommentedConfigurationNode> configLoader = HoconConfigurationLoader.builder().setPath(configPath).build();
TypeSerializerCollection serializers = TypeSerializers.getDefaultSerializers().newChild();
serializers.registerType(TypeToken.of(CommandGroup.class),new Serializer());
ConfigurationOptions options = ConfigurationOptions.defaults().setSerializers(serializers);
CommentedConfigurationNode configNode = configLoader.load(options);
for(Map.Entry<?,? extends CommentedConfigurationNode> entry : configNode.getChildrenMap().entrySet()){
try {
CommandGroup group = entry.getValue().getValue(TypeToken.of(CommandGroup.class));
commandGroups.add(group);
} catch (ObjectMappingException e) {
logger.error("Failed to load command group: "+entry.getKey(),e);
}
}
}
public class CommandGroup implements Runnable{
private String name;
private List<String> commandLines;
private long delay;
private boolean isDelayTick;
private TimeUnit delayTimeUnit;
private long interval;
private boolean isIntervalTick;
private TimeUnit intervalTimeUnit;
private CommandGroup(){}
void process(){
Task.Builder builder = Sponge.getScheduler().createTaskBuilder();
builder.execute(this);
if(isDelayTick){
builder.delayTicks(delay);
}else {
builder.delay(delay,delayTimeUnit);
}
if(isIntervalTick){
builder.intervalTicks(interval);
}else {
builder.interval(interval,intervalTimeUnit);
}
builder.submit(CommandsOnStarted.this);
}
@Override
public void run(){
logger.info("processing command group: {}",name);
CommandSource source = Sponge.getServer().getConsole();
for (String commandLine : commandLines) {
Sponge.getCommandManager().process(source,commandLine);
}
}
}
public class Serializer implements TypeSerializer<CommandGroup>{
@Override
public CommandGroup deserialize(TypeToken<?> typeToken, ConfigurationNode node) throws ObjectMappingException {
CommandGroup group = new CommandGroup();
group.name = node.getKey().toString();
group.commandLines = node.getNode("commands").getList(TypeToken.of(String.class), Collections.emptyList());
//delay
group.delay = node.getNode("delay","delay").getLong(0);
if(group.delay<0){
throw new ObjectMappingException("delay should not be below 0");
}
String timeUnitSting = node.getNode("delay","time_unit").getString("SECONDS").toUpperCase();
if("TICKS".equals(timeUnitSting)){
group.isDelayTick = true;
}else {
try {
group.delayTimeUnit = TimeUnit.valueOf(timeUnitSting);
}catch (IllegalArgumentException e){
throw new ObjectMappingException("Illegal argument for delay time unit",e);
}
}
//repetition
group.interval = node.getNode("repetition","interval").getLong(0);
if(group.interval<0){
throw new ObjectMappingException("interval should not be below 0");
}
timeUnitSting = node.getNode("repetition","time_unit").getString("SECONDS").toUpperCase();
if("TICKS".equals(timeUnitSting)){
group.isIntervalTick = true;
}else {
try {
group.intervalTimeUnit = TimeUnit.valueOf(timeUnitSting);
}catch (IllegalArgumentException e){
throw new ObjectMappingException("Illegal argument for interval time unit",e);
}
}
return group;
}
@Override
public void serialize(TypeToken<?> typeToken, CommandGroup commandGroup, ConfigurationNode configurationNode) throws ObjectMappingException {
//do nothing
}
}
}

复制代码

本插件所用所有代码均为原创,不存在借用/抄袭等行为

xmdhs

本帖最后由 xmdhs 于 2018-2-25 16:37 编辑

你厉害为了一个爱心自己做一个

下一页最后一页