ET9_WebGL_Dev/Server/Hotfix/System/ActorSystem.cs

using System;
using System.Threading.Tasks;
using Model;

namespace Hotfix
{
	[ObjectEvent]
	public class ActorComponentEvent : ObjectEvent<ActorComponent>, IAwake, IAwake<IEntityActorHandler>
	{
		public void Awake()
		{
			this.Get().Awake();
		}

		public void Awake(IEntityActorHandler iEntityActorHandler)
		{
			this.Get().Awake(iEntityActorHandler);
		}
	}

	/// <summary>
	/// 挂上这个组件表示该Entity是一个Actor, 它会将Entity位置注册到Location Server, 接收的消息将会队列处理
	/// </summary>
	public static class ActorSystem
	{
		public static void Awake(this ActorComponent self)
		{
			self.entityActorHandler = new CommonEntityActorHandler();
			self.queue = new EQueue<ActorMessageInfo>();
			self.actorId = self.Entity.Id;
			Game.Scene.GetComponent<ActorManagerComponent>().Add(self.Entity);
			self.HandleAsync();
		}

		public static void Awake(this ActorComponent self, IEntityActorHandler iEntityActorHandler)
		{
			self.entityActorHandler = iEntityActorHandler;
			self.queue = new EQueue<ActorMessageInfo>();
			self.actorId = self.Entity.Id;
			Game.Scene.GetComponent<ActorManagerComponent>().Add(self.Entity);
			self.HandleAsync();
		}

		public static async Task AddLocation(this ActorComponent self)
		{
			await Game.Scene.GetComponent<LocationProxyComponent>().Add(self.actorId);
		}

		public static async Task RemoveLocation(this ActorComponent self)
		{
			await Game.Scene.GetComponent<LocationProxyComponent>().Remove(self.actorId);
		}

		public static void Add(this ActorComponent self, ActorMessageInfo info)
		{
			self.queue.Enqueue(info);

			if (self.tcs == null)
			{
				return;
			}

			var t = self.tcs;
			self.tcs = null;
			t.SetResult(self.queue.Dequeue());
		}

		private static Task<ActorMessageInfo> GetAsync(this ActorComponent self)
		{
			if (self.queue.Count > 0)
			{
				return Task.FromResult(self.queue.Dequeue());
			}

			self.tcs = new TaskCompletionSource<ActorMessageInfo>();
			return self.tcs.Task;
		}

		private static async void HandleAsync(this ActorComponent self)
		{
			while (true)
			{
				try
				{
					ActorMessageInfo info = await self.GetAsync();
					await self.entityActorHandler.Handle(info.Session, self.Entity, info.Message);
				}
				catch (Exception e)
				{
					Log.Error(e.ToString());
				}
			}
		}
	}
}