swingfrog / summer Goto Github PK

因为Java对于所有对象都是复制拷贝的，所以如果使用Summer框架的逻辑代码里从框架获取了SessionContext对象，然后再用这个对象去调用syncPushToSessionContext，就会出现重复返回数据包的问题。
譬如逻辑代码是一个函数，函数开头从框架获取了SessionContext sctx；此时sctx里面的waitWriteQueue有5个包，当逻辑代码的函数执行完了，需要向这个sctx推送一条数据。此时逻辑代码里保存的sctx里面还是有5个包，但是框架里可能已经把这5个包都发出去了。此时调用syncPushToSessionContext(stcx)的时候，又会把这5个包重新发出去一次。
我觉得可以考虑把waitWriteQueue移出SessionContext，或者不允许逻辑代码获取SessionContext，或者将所有pushToSessionContext有关的函数都设置成private，不允许逻辑代码调用。

Summer/src/main/java/com/swingfrog/summer/server/rpc/RpcClientMgr.java:29

    public void add(SessionContext sctx, String cluster, String serverName) {
		log.debug("server register rpc client cluster[{}] serverName[{}] sessionContext[{}]", cluster, serverName, sctx);
		RpcClientCluster clientCluster = nameToCluster.get(cluster);
		if (clientCluster == null) {
			clientCluster = new RpcClientCluster();
			clientCluster.addClient(serverName, new RpcClientGroup());
			nameToCluster.put(cluster, clientCluster);
		}
		clientCluster.getRpcClientGroup(serverName).addClient(sctx);
	}

第一个serverName插入时会new RpcClientGroup()，第二个不会，应该改成

    public void add(SessionContext sctx, String cluster, String serverName) {
        log.debug("server register rpc client cluster[{}] serverName[{}] sessionContext[{}]", new Object[]{cluster, serverName, sctx});
        RpcClientCluster clientCluster = (RpcClientCluster)this.nameToCluster.get(cluster);
        if (clientCluster == null) {
            clientCluster = new RpcClientCluster();
            this.nameToCluster.put(cluster, clientCluster);
        }

        RpcClientGroup rcg = clientCluster.getRpcClientGroup(serverName);
        if (rcg == null) {
            rcg = new RpcClientGroup();
            clientCluster.addClient(serverName, rcg);
        }

        rcg.addClient(sctx);
    }

你写的测试例子中的TestService中的Test.of，其中of根本不认识啊 ，报错啊，兄弟，如何解决啊 ？

现在的json格式性能不太好，对于压力比较大的服务器用起来可能有点困难。
protobuf解析性能是json的8倍，网络流量可以节省3倍，对于用户量特别多的情况，还是protobuf比较现实一些

作者大大你好，这几天我测试了1000人在多服务器下的运作发现几个问题和需要优化的地方
1.Summer.getRandomRemoteClient 这个方法需要优化一下，假如随机拿到一个远程的服务器调用，此时这个服务器如果挂掉，会造成请求超时。建议优化成Summer.（a）syncSendRandomRemoteClitent，当有一台不可用的时候，进行轮询/随机切换到可用的为止
2.多台服务器之间进行连接时，部分服务器会一直不停 remove和add其他服务器，我查看代码貌似发现是一直在不停的触发channelInactive ，触发非常频繁。这个我不清楚是怎么造成的。

分布式部署主要面临的问题,服务端重启或者下线怎么处理?如何重连对用户无感知,有未发送的消息怎么处理?

请问一下初学 请问一下能不能提供有一些具体的业务的项目参考一下 有具体的http来往的业务

                                        Summer Server Powered by Toke 2018

2019-10-23 17:55:03:272 [main] INFO [] summer init...
2019-10-23 17:55:03:272 [main] INFO [] config load...
2019-10-23 17:55:03:382 [main] ERROR [] null
java.lang.NumberFormatException: null
at java.lang.Integer.parseInt(Integer.java:542)
at java.lang.Integer.valueOf(Integer.java:766)
at com.swingfrog.summer.config.ConfigUtil.getValueByTypeAndString(ConfigUtil.java:49)
at com.swingfrog.summer.config.ConfigUtil.loadDataWithBean(ConfigUtil.java:34)
at com.swingfrog.summer.db.repository.AsyncCacheRepositoryMgr.loadConfig(AsyncCacheRepositoryMgr.java:41)
at com.swingfrog.summer.app.Summer.hot(Summer.java:90)
at com.test.summerDemo.game.GameApp.main(GameApp.java:29)
2019-10-23 17:55:03:397 [main] INFO [] async cache repository manager loading config, core thread num[16]
2019-10-23 17:55:03:397 [main] INFO [] task init
2019-10-23 17:55:03:444 [main] INFO [] container init...
2019-10-23 17:55:03:460 [main] INFO [] register remote ChatRemote
2019-10-23 17:55:03:460 [main] INFO [] server init...

Spring,Summer,Autumn,Winter😂 强！

感觉挺不错的
多增加一些例子
比如echo server 这样的,更便于理解

后期会加业务吗

报错信息如下：
hello, you need to fill in two parameters to start the application.

args:
[app jar] [main class]

example:
xxx.jar xxx.xxx.xxx.xxx

看样子要给vm传一个jar包的名字作为参数，后面的我猜应该传ip但是，传了以后继续报错如下：
Connected to the target VM, address: '127.0.0.1:64461', transport: 'socket'
����: �Ҳ������޷��������� Summer.jar
Disconnected from the target VM, address: '127.0.0.1:64461', transport: 'socket'

Process finished with exit code 1
而且没有数据库文件，后面怎么执行？

package com.swingfrog.summer.protocol.stringline 

包下的 StringPasswordLineDecoder在使用了ByteBuf后未进行资源回收

在server.properties中开启密码验证，使用websocket连接长时间运行后，会导致netty报内存不足。

使用netty自带的工具可以检测出来，启动项目时添加vm参数
-Dio.netty.leakDetectionLevel=PARANOID

建议在StringPasswordLineDecoder.decode增加

ReferenceCountUtil.release(msg);

目前条件比较有限,如果网关和客户端之间使用protobuf,网关需要转发给其他服务处理业务,最好是直接把protobuf丢到其他节点.但是看到ClientInitializer里面只支持到两种,如果加上protobuf就有意思啦,不过总体来说Summer用起来还是挺舒服

我用了你的框架，感觉有一个问题要解决：就是游戏服务器的多线程复杂问题。虽然你分了几个事件队列，但感觉依然解决不了并发的风险问题。我们项目用你的这个框架，在并发问题上放弃了，最后还是回到单线程模型。建议你可以研究一下AKKA和STM。