xinQing 最近的时间轴更新 xinQing 最近的时间轴更新 |
xinQingV2EX 第 285361 号会员，加入于 2018-01-22 15:50:05 +08:00 |
http://www.fishfish.tk/
| 2 年 Java 经验（含 1 年大数据），武汉招聘翻了挺久，基本 3 年经验起步，心塞。 武汉 • xinQing • 105 天前 • 最后回复来自 zj8614 | 8 |
| eureka-client for golang Go • xinQing • 212 天前 |
| requests for golang Go • xinQing • 209 天前 • 最后回复来自 xinQing | 24 |
xinQing 最近回复了
140 天前 回复了 xinQing 创建的主题 › 武汉 › 2 年 Java 经验（含 1 年大数据），武汉招聘翻了挺久，基本 3 年经验起步，心塞。 |
@xgfan 可以哈
140 天前 回复了 xinQing 创建的主题 › 武汉 › 2 年 Java 经验（含 1 年大数据），武汉招聘翻了挺久，基本 3 年经验起步，心塞。 |
@zotobcs 好的，试试哈
193 天前 回复了 kuangjia2018 创建的主题 › MacBook Pro › 话说你们 Mac 用的都是啥邮箱客户端？用了不下 10 个，全部凉凉... |
spark
194 天前 回复了 hbs2019 创建的主题 › 程序员 › 个人网站正式开通上线~ |
讲道理 ui 有点丑哇
204 天前 回复了 Graves 创建的主题 › Java › springboot 集成了 netty，启动后内置 tomcat 没有启动？ |
你是不是启动 netty 阻塞了 main 啊，用一个新的线程启动 netty 就好了。我之前在 spring boot 中集成 netty 做 websocket 聊天，是在 spring 容器刷新后，再用新线程启动 netty 服务。下面的事例代码可以参考下：
/**
* spring 容器刷新时启动 netty 的 WebSocket 服务
*
* Created by xuan on 2018/3/5
*/
@Component
public class ApplicationRefreshListener implements ApplicationListener<ContextStartedEvent> {
private static final Logger LOG = LoggerFactory.getLogger(ApplicationRefreshListener.class);
private ExecutorService webSocketSinglePool;
@PostConstruct
public void setup() {
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
.setNameFormat("webSocketSinglePool-%d").build();
webSocketSinglePool = new ThreadPoolExecutor(1, 1, 0L,
TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(1024),
namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());
LOG.info("webSocketSinglePool init.");
}
@Override
public void onApplicationEvent(ContextRefreshedEvent event) {
runWebSocketServer(event.getApplicationContext());
}
private void runWebSocketServer(ApplicationContext applicationContext) {
final WebSocketServer webSocketServer = applicationContext.getBean(WebSocketServer.class);
webSocketSinglePool.execute(() -> {
try {
webSocketServer.listenAndServe();
} catch (Exception e) {
LOG.error("webSocket listen and serve error.", e);
}
});
}
@PreDestroy
public void cleanup() {
webSocketSinglePool.shutdown();
LOG.info("webSocketSinglePool destroyed.");
}
}
/**
* spring 容器刷新时启动 netty 的 WebSocket 服务
*
* Created by xuan on 2018/3/5
*/
@Component
public class ApplicationRefreshListener implements ApplicationListener<ContextStartedEvent> {
private static final Logger LOG = LoggerFactory.getLogger(ApplicationRefreshListener.class);
private ExecutorService webSocketSinglePool;
@PostConstruct
public void setup() {
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
.setNameFormat("webSocketSinglePool-%d").build();
webSocketSinglePool = new ThreadPoolExecutor(1, 1, 0L,
TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(1024),
namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());
LOG.info("webSocketSinglePool init.");
}
@Override
public void onApplicationEvent(ContextRefreshedEvent event) {
runWebSocketServer(event.getApplicationContext());
}
private void runWebSocketServer(ApplicationContext applicationContext) {
final WebSocketServer webSocketServer = applicationContext.getBean(WebSocketServer.class);
webSocketSinglePool.execute(() -> {
try {
webSocketServer.listenAndServe();
} catch (Exception e) {
LOG.error("webSocket listen and serve error.", e);
}
});
}
@PreDestroy
public void cleanup() {
webSocketSinglePool.shutdown();
LOG.info("webSocketSinglePool destroyed.");
}
}
204 天前 回复了 darkem4869 创建的主题 › Java › 关于管理 storm bolt 运行时间的问题 |
storm 没这样玩啊，都是常驻运行，关掉干啥，复用不行么
204 天前 回复了 h8743 创建的主题 › Java › 现在 Java 爬虫有啥推荐的么？ webmagic 很久没维护了 |
这个 webmagic 很成熟了啊，源码也比较简单，推荐使用～
Select Language