clickhouse 牛逼
2000pv 妥妥的大数据

nodebb

当然可以
这个问题就是一台主机是不是只能有 65536 个 tcp 连接

可以就近找香港的
不清楚国内形势，狭隘了啊

有很多程序员一天的工资都大于 1200
悬赏，原来也就一天工资

我一初中同学的朋友圈，跑车、旅游，你能怎么办呢

你这是在 connect 连代理，练完之后传输的才是被 http over tls 的东西，也就是一串乱码

要理解这个东西，你去搜下 http connect 方法就行。

需要自成体系的学习，咋遇到个问题上 V2EX 呢

眼睛本身是没有痛觉神经的

说一个我觉得吧

不要在构造函数内暴露 this

如果你在构造函数内写逻辑，你就可能暴露 this

菜头太孤独了

foobar 肯定是马爸爸说的福报啊

@Leonard 离职手续不办了吗

@Aruforce 这代码我运行了下，用 nc localhost 8090 测试了下，没有问题啊

你说的空转是什么意思？

不要总是感觉有问题，永远没有最优解，都是权衡和妥协。最怕你觉得这样有问题，然后就什么都不做。

优化是后面的事。

另外，说真的，就是这样了，不要觉得有啥问题。真可以增加的就是线程池了

@Aruforce 看错了，没看到你用了两个 selector 。

你现在问题是线程 1 register 、线程 2 select，死锁了。解决很简单，用个生产者消费者模型，把要 register 的 channel 放到队列中，线程二在每次 select 前先 register 队列中的 channel 。这时候你可能又要问了，万一线程 2 一直阻塞在 select 时，怎么办？ 答案：用 selectNow()或 select （ timeout ）。


刚刚看了 netty 源码中怎么进行 register 的，他也是生产者消费者模型，由进行 select 的线程来 register 。代码如下：

AbstractChannel.java (Netty 4.1)：

@Override
public final void register(EventLoop eventLoop, final ChannelPromise promise) {
ObjectUtil.checkNotNull(eventLoop, "eventLoop");
if (isRegistered()) {
promise.setFailure(new IllegalStateException("registered to an event loop already"));
return;
}
if (!isCompatible(eventLoop)) {
promise.setFailure(
new IllegalStateException("incompatible event loop type: " + eventLoop.getClass().getName()));
return;
}

AbstractChannel.this.eventLoop = eventLoop;

if (eventLoop.inEventLoop()) {
register0(promise); // 这里不会走到
} else {
try {
// eventLoop 就是 netty 中线程，提交一个 register 任务，后面会被执行
eventLoop.execute(new Runnable() {
@Override
public void run() {
register0(promise);
}
});
} catch (Throwable t) {
logger.warn(
"Force-closing a channel whose registration task was not accepted by an event loop: {}",
AbstractChannel.this, t);
closeForcibly();
closeFuture.setClosed();
safeSetFailure(promise, t);
}
}
}

问题确实是 select 和 register 都要获取同样的锁。

你现在是启动两个线程，一个 select-accept-register，另一个 select-read/write 。除了锁的问题哈，还有你会丢失 accept 和读写事件，线程 1 会忽略读写，线程 2 会忽略 accept 。

楼主知道 reactor 模式吗？一个线程负责接收事件（ accept 、read 、write ），后面一个线程池负责处理这些事件。

应该长这样：一个线程 select-accept/read/write->由线程池来处理不同事件（ accept 可以直接在原线程进行 register ）

PS：实践到这里差不多了，可以看 netty 了。先用用 netty，然后看下 netty 源码，相信就能清楚。

我想做，并且搭了一个论坛，可以没人发帖

https://bbs.arloor.com

@fxxkgw 大佬跳槽的话想做什么啊

看下官方文档中 date 和 date_range 这两个数据类型，相信就能解决

应届生这也差了点才对。。