网关广播socket包优化

[253980289]

请教网关服务广播socket包时如何优化打包过程(避免pb和websocket等多次打包)？

[hanxi]

可以参考这个网关的实现？cb 函数 return 1 时，数据就不会 free ，自己广播完之后手动 free 。

skynet/service-src/service_gate.c

Lines 281 to 312 in 5608d39

	_cb(struct skynet_context * ctx, void * ud, int type, int session, uint32_t source, const void * msg, size_t sz) {
	struct gate *g = ud;
	switch(type) {
	case PTYPE_TEXT:
	_ctrl(g , msg , (int)sz);
	break;
	case PTYPE_CLIENT: {
	if (sz <=4 ) {
	skynet_error(ctx, "Invalid client message from %x",source);
	break;
	}
	// The last 4 bytes in msg are the id of socket, write following bytes to it
	const uint8_t * idbuf = msg + sz - 4;
	uint32_t uid = idbuf[0] | idbuf[1] << 8 | idbuf[2] << 16 | idbuf[3] << 24;
	int id = hashid_lookup(&g->hash, uid);
	if (id>=0) {
	// don't send id (last 4 bytes)
	skynet_socket_send(ctx, uid, (void*)msg, sz-4);
	// return 1 means don't free msg
	return 1;
	} else {
	skynet_error(ctx, "Invalid client id %d from %x",(int)uid,source);
	break;
	}
	}
	case PTYPE_SOCKET:
	// recv socket message from skynet_socket
	dispatch_socket_message(g, msg, (int)(sz-sizeof(struct skynet_socket_message)));
	break;
	}
	return 0;
	}

[253980289]

这个方案是不是要直接修改skynet的源码？另外，我期望的是对于大多数情况保持原始规则，即发送后即free，但能通过不同的接口可接口参数来控制可以允许不free。

[253980289]

我目前的做法是在广播和组播包时设计专门的打包接口，将其转为字符串模式以实现共享，不然会因多次释放包数据而崩溃。但不确认此方案是否合理。

function M.pack_down_all_tostring(msg_id, data, seq, encrypt_, handle)
	local data, sz = M.pack_down_all(msg_id, data, seq, encrypt_, handle)
	return netpack.tostring(data, sz)
end