zhuangjinjin / piccolo

Netty4长连接网关

Hi there 👋

• 🌱 I’m currently learning golang, dubbo
• 🤔 Reject 996

piccolo's Issues

在线玩家列表缓存丢失问题

玩家在线且可以正常上发和接收回包，但是不在redis的oul缓存内。现在世界聊天的逻辑是从网关的oul取在线uids的，发现有些uid收不到消息，经查没有收到消息的uid不在oul缓存内。

借鉴mpush?

和mpush特别像, 很像mpush的升级版

IdGenBuilder创建IdGen实例时，配置capacity大于10000时启动报错

java.lang.IllegalArgumentException: data's length invalid, len:10000
at io.github.ukuz.piccolo.api.external.common.Assert.isTrue(Assert.java:47)
at io.github.ukuz.piccolo.client.id.snowflake.IdBuffer.write(IdBuffer.java:62)
at io.github.ukuz.piccolo.client.id.snowflake.SnowflakeIdGenDelegate.writeData(SnowflakeIdGenDelegate.java:144)
at io.github.ukuz.piccolo.client.id.snowflake.IdGenClientHandler.received(IdGenClientHandler.java:47)
at io.github.ukuz.piccolo.client.common.MultiMessageClientHandler.lambda$received$0(MultiMessageClientHandler.java:53)

博主的抽象能力、细节把控能力令人惊艳

博主的抽象能力、细节把控能力令人惊艳，但是读者想弄明白也需要花费不少时间

架构图裂图了

您好，架构图裂图了，能重新上传下么？没有架构图看着有些吃力，谢谢~~

(Re-)joining group问题

网关运行状态，重启业务系统，业务系统启动完成后一直(Re-)joining group，需要等待3-5分钟才能恢复正常。现在业务系统有两组，其中一组重启就会影响到另外一组，也就是两组都会进入(Re-)joining group状态。部分日志：
2020-10-30 17:54:21.188 INFO [player-controller] --- [piccolo-mq-t-3] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-3, groupId=piccolo-consumer3] (Re-)joining group
2020-10-30 17:54:51.155 INFO [player-controller] --- [piccolo-mq-t-1] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-1, groupId=piccolo-consumer3] Group coordinator 10.0.1.48:9092 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery
2020-10-30 17:54:51.155 INFO [player-controller] --- [piccolo-mq-t-2] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-2, groupId=piccolo-consumer3] Group coordinator 10.0.1.48:9092 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery
2020-10-30 17:54:51.210 INFO [player-controller] --- [piccolo-mq-t-3] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-3, groupId=piccolo-consumer3] Group coordinator 10.0.1.48:9092 (id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery
2020-10-30 17:54:51.257 INFO [player-controller] --- [piccolo-mq-t-2] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-2, groupId=piccolo-consumer3] Discovered group coordinator 10.0.1.48:9092 (id: 2147483647 rack: null)
2020-10-30 17:54:51.257 INFO [player-controller] --- [piccolo-mq-t-1] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-1, groupId=piccolo-consumer3] Discovered group coordinator 10.0.1.48:9092 (id: 2147483647 rack: null)
2020-10-30 17:54:51.257 INFO [player-controller] --- [piccolo-mq-t-2] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-2, groupId=piccolo-consumer3] (Re-)joining group
2020-10-30 17:54:51.257 INFO [player-controller] --- [piccolo-mq-t-1] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-1, groupId=piccolo-consumer3] (Re-)joining group
2020-10-30 17:54:51.312 INFO [player-controller] --- [piccolo-mq-t-3] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-3, groupId=piccolo-consumer3] Discovered group coordinator 10.0.1.48:9092 (id: 2147483647 rack: null)
2020-10-30 17:54:51.312 INFO [player-controller] --- [piccolo-mq-t-3] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-3, groupId=piccolo-consumer3] (Re-)joining group
2020-10-30 17:55:51.480 INFO [player-controller] --- [piccolo-mq-t-2] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-2, groupId=piccolo-consumer3] (Re-)joining group
2020-10-30 17:55:51.480 INFO [player-controller] --- [piccolo-mq-t-1] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-1, groupId=piccolo-consumer3] (Re-)joining group
2020-10-30 17:55:51.540 INFO [player-controller] --- [piccolo-mq-t-3] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-3, groupId=piccolo-consumer3] Discovered group coordinator 10.0.1.48:9092 (id: 2147483647 rack: null)
2020-10-30 17:55:51.540 INFO [player-controller] --- [piccolo-mq-t-3] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-3, groupId=piccolo-consumer3] (Re-)joining group
2020-10-30 17:56:16.110 INFO [player-controller] --- [piccolo-mq-t-2] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-2, groupId=piccolo-consumer3] Successfully joined group with generation 4
2020-10-30 17:56:16.111 INFO [player-controller] --- [piccolo-mq-t-2] o.a.k.c.c.i.ConsumerCoordinator: [Consumer clientId=consumer-2, groupId=piccolo-consumer3] Setting newly assigned partitions []
2020-10-30 17:56:16.111 INFO [player-controller] --- [piccolo-mq-t-1] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-1, groupId=piccolo-consumer3] Successfully joined group with generation 4
2020-10-30 17:56:16.111 INFO [player-controller] --- [piccolo-mq-t-1] o.a.k.c.c.i.ConsumerCoordinator: [Consumer clientId=consumer-1, groupId=piccolo-consumer3] Setting newly assigned partitions []
2020-10-30 17:56:16.113 INFO [player-controller] --- [piccolo-mq-t-3] o.a.k.c.c.i.AbstractCoordinator: [Consumer clientId=consumer-3, groupId=piccolo-consumer3] Successfully joined group with generation 4
2020-10-30 17:56:16.113 INFO [player-controller] --- [piccolo-mq-t-3] o.a.k.c.c.i.ConsumerCoordinator: [Consumer clientId=consumer-3, groupId=piccolo-consumer3] Setting newly assigned partitions []

有没有提供用户上线事件接口

上线的时候，网关有提供上线事件的接口吗，客户端做了自动重连，重连的时候只会握手和绑定userid，业务系统有写数据要上限的时候加载到缓存里，想问你一下有没有上线事件，有的话就可以在事件里做

IdGenBuilder.capacity(int capacity)方法内断言变量引用错误

IdGenBuilder.capacity(int capacity)方法内断言变量引用错误 line:38

piccolo-client端offline每次都会触发3次

客户端离线，网关push离线消息到offline topic，client端每次都会接收到3次offline事件。