首页   注册   登录
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
宝塔
V2EX  ›  xinQing  ›  全部回复第 1 页 / 共 2 页
回复总数  23
1  2  
@xgfan 可以哈
@zotobcs 好的,试试哈
spark
195 天前
回复了 hbs2019 创建的主题 程序员 个人网站正式开通上线~
讲道理 ui 有点丑哇
你是不是启动 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.");
}

}
205 天前
回复了 darkem4869 创建的主题 Java 关于管理 storm bolt 运行时间的问题
storm 没这样玩啊,都是常驻运行,关掉干啥,复用不行么
这个 webmagic 很成熟了啊,源码也比较简单,推荐使用~
209 天前
回复了 xinQing 创建的主题 Go requests for golang
@insert000 可以哈,没事的。如果在使用过程中有问题,希望可以反馈下,大家一起完善哈
212 天前
回复了 xinQing 创建的主题 Go requests for golang
如果大家想使用超时、KeepAlive 等功能,可以自定义 Client、Transport 替换 http 包 DefaultClient、DefaultTransport。

func customHttp() {

client := &http.Client{
Transport: &Transport
Timeout: 5 * time.Second,
}
text, err := requests.Request("https://github.com/xuanbo", "OPTIONS", client).
Send().
Text()
if err != nil {
panic(err)
}
fmt.Println(text)
}
212 天前
回复了 xinQing 创建的主题 Go requests for golang
@xkeyideal 这个有重试,超时,更完善: https://github.com/parnurzeal/gorequest
212 天前
回复了 xinQing 创建的主题 Go requests for golang
@abel1989 你要 fork 代码之后,然后提交一个 pull request,我这边再合并过去哈
212 天前
回复了 xinQing 创建的主题 Go requests for golang
@newmind parnurzeal/gorequest 这给功能更强大,而且维护的人多,生产用比较放心:)
212 天前
回复了 xinQing 创建的主题 Go requests for golang
@abel1989 谢谢支持: )
212 天前
回复了 xinQing 创建的主题 Go requests for golang
@inframe 哈哈
212 天前
回复了 xinQing 创建的主题 Go requests for golang
@kidlj 只用了标准库,源码也才 200 行,比较适合初学者,有问题也可以自己改~
213 天前
回复了 xinQing 创建的主题 Go requests for golang
@uasier 嘻嘻,3q
213 天前
回复了 xinQing 创建的主题 Go requests for golang
@jinliming2 嗯嗯,谢谢建议哈。主要平时就主要用 GET、POST、PUT、DELETE ; PATCH、HEAD、OPTION 不咋用,我后面加上
213 天前
回复了 xinQing 创建的主题 Go requests for golang
@gowk 谢谢哈
spring 全家桶( ssm+各种杂七杂八依赖),再加上大数据的( hadoop、hive、hbase ),打包成 war500M+
1  2  
关于   ·   FAQ   ·   API   ·   我们的愿景   ·   广告投放   ·   感谢   ·   实用小工具   ·   935 人在线   最高记录 5043   ·     Select Language
创意工作者们的社区
World is powered by solitude
VERSION: 3.9.8.3 · 24ms · UTC 20:31 · PVG 04:31 · LAX 12:31 · JFK 15:31
♥ Do have faith in what you're doing.