Method sendDirect

ZezeJava/ZezeJava/src/main/java/Zeze/Arch/Online.java:880–940

(@NotNull Set<BLoginKey> loginKeys, long typeId, @NotNull Binary fullEncodedProtocol,
						  boolean trySend)

	// 可在事务外执行
	public int sendDirect(@NotNull Set<BLoginKey> loginKeys, long typeId, @NotNull Binary fullEncodedProtocol,
						  boolean trySend) {
		if (loginKeys.isEmpty())
			return 0;
		var groups = new HashMap<String, LinkRoles>();
		var links = providerApp.providerService.getLinks();
		for (var loginKey : loginKeys) {
			var account = loginKey.getAccount();
			var clientId = loginKey.getClientId();
			var online = _tonline.selectDirty(account);
			if (online == null) {
				if (!trySend) {
					logger.info("sendDirects({}): not found account={} in _tonline",
							getTypeId(fullEncodedProtocol), account);
				}
				continue;
			}
			var login = online.getLogins().get(clientId);
			if (login == null) {
				if (!trySend) {
					logger.info("sendDirects({}): not found login for clientId={} account={}",
							getTypeId(fullEncodedProtocol), clientId, account);
				}
				continue;
			}
			var link = login.getLink();
			var state = link.getState();
			if (state != eLogined) {
				if (!trySend) {
					logger.info("sendDirects({}): state={} != eLogined for clientId={} account={}",
							getTypeId(fullEncodedProtocol), state, clientId, account);
				}
				continue;
			}
			var linkName = link.getLinkName();
			// 后面保存connector.socket并使用，如果之后连接被关闭，以后发送协议失败。
			var group = groups.get(linkName);
			if (group == null) {
				var linkSocket = getLinkSocket(links, linkName, account, clientId); // maybe null
				groups.put(linkName, group = new LinkRoles(linkName, linkSocket, typeId, fullEncodedProtocol));
			}
			group.send.Argument.getLinkSids().add(link.getLinkSid());
			group.accounts.add(loginKey);
		}
		int sendCount = 0;
		for (var group : groups.values()) {
			if (null == group.linkSocket) {
				processErrorSids(group.send.Argument.getLinkSids(), group);
				continue; // link miss process done
			}

			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++;