Method tryPushMessage

ZezeJava/ZezeJava/src/main/java/Zeze/MQ/MQSingle.java:115–143

()

	}

	private void tryPushMessage() {
		if (null == pendingPushMessage && !messageQueue.isEmpty() && bindSocket != null) {
			pendingPushMessage = new PushMessage();
			pendingPushMessage.Argument.setTopic(topic);
			pendingPushMessage.Argument.setPartitionIndex(partitionIndex);
			pendingPushMessage.Argument.setSessionId(bindSessionId);
			var message = messageQueue.peek();
			pendingPushMessage.Argument.setMessage(message);
			pendingPushMessage.Send(bindSocket, (p) -> {
				lock();
				try {
					loadCounter.incrementAndGet(); // 处理失败也进行计数。

					if (pendingPushMessage.getResultCode() == 0) {
						messageQueue.poll();
						fileWithIndex.increaseFirstMessageId();
						tryStartBackgroundFill();
					}

					// 不管是否失败，都尝试重新pushMessage。出错的时候要不要随机延迟一下再重试？
					pendingPushMessage = null;
					tryPushMessage();
				} finally {
					unlock();
				}
				return 0;
			});
		}
	}

	public void bind(long sessionId, AsyncSocket socket) {
		lock();