因为Java对于所有对象都是复制拷贝的，所以如果使用Summer框架的逻辑代码里从框架获取了SessionContext对象，然后再用这个对象去调用syncPushToSe

SessionContext里面保存waitWriteQueue貌似有问题 about summer HOT 1 CLOSED

swingfrog commented on May 18, 2024

SessionContext里面保存waitWriteQueue貌似有问题

from summer.

Comments (1)

SwingFrog commented on May 18, 2024

首先感谢您对summer的关注。
在summer中sctx (sessionContext) 是与连接绑定的，只要链路还在，sctx就不销毁，也就是说链路仅对应一个sctx。可能您说的是http情况，http协议下每次请求进来都是一个新的链路，也就是每次都会新建个sctx，但返回完会立马销毁。
对于sctx里面的waitWriteQueue这个问题，当链路可写时，会把waitWriteQueue里面的数据包依次写出。

push和响应都是调用以下代码，当链路可写时且队列为空则立刻写出，否则添加到队列中。

		if (sctx.getWaitWriteQueueSize() == 0 && ctx.channel().isWritable()) {
			ctx.writeAndFlush(response);
		} else {
			sctx.getWaitWriteQueue().add(response);
		}

下面这个是ServerStringHandler里面的代码，当触发可写事件时将队列中的数据包逐个写出。

	public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
		super.channelWritabilityChanged(ctx);
		SessionContext sctx = serverContext.getSessionContextGroup().getSessionByChannel(ctx);
		while (ctx.channel().isActive() && ctx.channel().isWritable() && sctx.getWaitWriteQueueSize() > 0) {
			ctx.writeAndFlush(sctx.getWaitWriteQueue().poll());
		}
	}

from summer.

Recommend Projects