[Bug] Global flow control is not work in MessageTransferTask

[lrhkobe]

Bug Report

Describe the bug

The global flow control is not work，because the current logic exist problem.

The wrong way:

public void run() {
	...
	if (!rateLimiter.tryAcquire(TRY_PERMIT_TIME_OUT, TimeUnit.MILLISECONDS)) {
		doFlowControlHandle();
		return;
	}

	doSend();
	...
}

In this way, the send thread releases the token immediately after obtaining it.

The right way:

public void run() {
	...
	if (rateLimiter.tryAcquire(TRY_PERMIT_TIME_OUT, TimeUnit.MILLISECONDS)) {
		doSend();
	}else{
		doFlowControlHandle();
		return;
	}

	...
}

Current in MessageTransferTask.java:

public void run() {
	...
	if (!cmd.equals(RESPONSE_TO_SERVER) && !eventMeshTCPServer.getRateLimiter().tryAcquire(TRY_PERMIT_TIME_OUT, TimeUnit.MILLISECONDS)) {
		msg.setHeader(new Header(replyCmd, OPStatus.FAIL.getCode(), "Tps overload, global flow control", pkg.getHeader().getSeq()));
		ctx.writeAndFlush(msg).addListener(
				new ChannelFutureListener() {
					@Override
					public void operationComplete(ChannelFuture future) throws Exception {
						Utils.logSucceedMessageFlow(msg, session.getClient(), startTime, taskExecuteTime);
					}
				}
		);
		logger.warn("======Tps overload, global flow control, rate:{}! PLEASE CHECK!========", eventMeshTCPServer.getRateLimiter().getRate());
		return;
	}

	doSend();
	...
}

Current code in EventMesh is same with the wrong way.

[ruanwenjun]

@lrhkobe This two ways may be the same. It seems that the RateLimiter will release tokens at a rate of a given number.