he
he
从 openIM.log 报错上来看,是因为无法连接 kafka。报错的日志显示,服务 open_im_push 运行时,连接的 ip:port 是:127.0.0.1:9092,但我在 config.yaml 中配置的是 [192.168.3.8:19092], 并且我在函数 NewMConsumerGroup 中打了 log,在日志中打印的 addr 为 [192.168.3.8:19092] 我不知道在 kafka 消费时,为啥连接的是 127.0.0.1:9092,导致open_im_push 服务无法启动 openIM.log 中打印的 addr 和报错分别为: NewMConsumerGroup addr: [192.168.3.8:19092]...
你好,大佬 我只发现往小根堆里加定时任务,但是处理到期事件的时候,什么都没做 是应该在 下图中 TODO 位置加上 关闭 http 连接的代码吗?还是我没找到释放 http 连接的位置?
大佬,说的不对的话,请帮忙指出来 1. http 读事件,不要把 EPOLLONESHOT 注册到 epoll 上。 每个 http 请求的处理都是单线程的,处理完每次 http 事件后,根据 old_event 和 new_event,比对一下(当前最新版本是没有对比的,都是 EPOLL_CTL_MOD,关于事件的二次注册这块目前写的感觉有点乱),来确定 EPOLL_CTL_MOD EPOLL_CTL_ADD EPOLL_CTL_DEL 或者不操作。这样能减少系统调用 epoll_ctl 2. 小根堆定时器那里,我觉得最好使用 epoll_wait + 小根堆来实现,用小根堆的最小时间 timeout 来唤醒 epoll_wait,唤醒后,堆顶结点肯定超时了,libevent...