Method sendDirect

ZezeJava/ZezeJava/src/main/java/Zeze/Game/Online.java:1313–1369

(@NotNull Iterable<Long> roleIds, long typeId, @NotNull Binary fullEncodedProtocol,
						  boolean trySend)

	// 可在事务外执行
	public int sendDirect(@NotNull Iterable<Long> roleIds, long typeId, @NotNull Binary fullEncodedProtocol,
						  boolean trySend) {
		var roleIdSet = new LongHashSet();
		for (var roleId : roleIds)
			roleIdSet.add(roleId); // 去重
		if (roleIdSet.isEmpty())
			return 0;
		var groups = new HashMap<String, LinkRoles>();
		var links = providerApp.providerService.getLinks();
		for (var it = roleIdSet.iterator(); it.moveToNext(); ) {
			var roleId = it.value();
			var onlineShared = _tOnlineShared.selectDirty(roleId);
			if (onlineShared == null) {
				if (!trySend) {
					logger.info("sendDirects({}): not found roleId={} in _tonline",
							getTypeId(fullEncodedProtocol), roleId);
				}
				continue;
			}
			var link = onlineShared.getLink();
			var state = link.getState();
			if (state != eLogined) {
				if (!trySend) {
					logger.info("sendDirects({}): state={} != eLogined for roleId={}",
							getTypeId(fullEncodedProtocol), state, roleId);
				}
				continue;
			}
			var linkName = link.getLinkName();
			// 后面保存connector.socket并使用，如果之后连接被关闭，以后发送协议失败。
			var group = groups.get(linkName);
			if (group == null) {
				var linkSocket = getLinkSocket(links, linkName, roleId); // maybe null
				groups.put(linkName, group = new LinkRoles(linkName, linkSocket, typeId, fullEncodedProtocol));
			}
			group.send.Argument.getLinkSids().add(link.getLinkSid());
			group.roleIds.add(roleId);
		}

		int sendCount = 0;
		for (var group : groups.values()) {
			if (group.linkSocket == null) {
				processErrorSids(group.send.Argument.getLinkSids(), group);
				continue; // link miss process done
			}

			group.roleIds.foreach(this::setLocalActiveTimeIfPresent);
			if (group.send.Send(group.linkSocket, rpc -> {
				var send = group.send;
				var errorSids = send.isTimeout() ? send.Argument.getLinkSids() : send.Result.getErrorLinkSids();
				processErrorSids(errorSids, group);
				return Procedure.Success;
			}))
				sendCount++;
		}
		return sendCount;
	}