启动服务端
关于可配置细节,参考 “配置类” 的内容。
启动一个简单的服务端
- 原生接口方式
public class Demo {
public static void main(String[] args) throws Throwable {
//创建监听器
Listener listener = new SimpleListener(){
@Override
public void onMessage(Session session, Message message) throws IOException {
System.out.println(message);
}
};
//启动服务
Server server = SocketD.createServer("sd:ws")
.config(c -> c.port(8602).sslContext(null)) //如果有 ssl 需要,添加 sslContext
.listen(listener)
.start();
//添加安全停止
Runtime.getRuntime().addShutdownHook(new Thread(()->{
RunUtils.runAndTry(server::stop);
}));
}
}
- Ioc 容器管理方式(假代码示意)
@Component
public class ListenerImpl implements Listener { //内置有多个不同功能的监听器,可借用
...
}
@Component
public class ServerLifecycle implements LifecycleBean {
private Server server ;
@Inject
private Listener listener;
@Override
public void start() {
server = SocketD.createServer("sd:ws")
.config(c -> c.port(8602))
.listen(listener)
.start();
}
@Override
public void stop() {
if(server != null) {
server.stop();
}
}
}
附:服务端接口
/**
* 服务端接口
*/
public interface Server {
/**
* 获取台头
* */
String getTitle();
/**
* 获取配置
* */
ServerConfig getConfig();
/**
* 配置
*/
Server config(ServerConfigHandler configHandler);
/**
* 监听
*/
Server listen(Listener listener);
/**
* 启动
*/
Server start() throws IOException;
/**
* 停止
*/
void stop();
}