Cysharpが公開したMessagePipeですが「個人的にUniTask, UniRx同様に使いこなしたい！」
ということで調べた内容を少しずつ記事にしていきます

以下の開発環境でMessagePipeを使用しています

Unity
Zenject
MessgePipe v1.6.1

MessagePipeとは？
という所は他の方が素晴らしい記事を挙げられているのでここでは書きません
Zenjectについても同じく

以下の記事がMessagePipeについて詳しく載せられています！

今回はZenject, Unity環境でとりあえずイベントを送受信を行う。
という部分のみの記事です

UnityTestRunnerで触ってみる

いきなりですが「覚えるためには実践する」ということで
とりあえずUnityTestRunnerでいじって見ることにします

MessagePipeとZenjectの組み合わせでUnityTestRunnerを実行してみました

using NUnit.Framework;
using MessagePipe;
using Zenject;
using UnityEngine;


public class Test
{
    // イベント送る方
    public class Publisher
    {
        [Inject] private IPublisher<MyEvent> _publisher;

        public void Send(MyEvent ev) =>
            _publisher.Publish(ev);
    }

    // イベント受け取る方
    public class Subscriber
    {
        [Inject] private ISubscriber<MyEvent> _subscriber;

        public void Setup() =>
            _subscriber.Subscribe(x => Debug.Log($"{x.Message}"));
    }

    // 送るイベント
    public class MyEvent 
    { 
        public string Message; 
    }


    private DiContainer _container;

    [Test]
    public void SimpleTest()
    {
        _container = new DiContainer();
            
        _container.BindMessageBroker<MyEvent>(_container.BindMessagePipe());

        // イベントを受ける方
        var sub = _container.Instantiate<Subscriber>();
        sub.Setup();
        
        // イベントを投げる方
        var publisher = _container.Instantiate<Publisher>();
        publisher.Send(new MyEvent { Message = "テストメッセージ" });
    }
}

これでテストメッセージという文字列がログに表示されました

流れ

ZenjectのDIContainerを生成する
BindMessageBroker<MyEvent>(_container.BindMessagePipe()); でMyEventイベントを送受信できるようにする
_container.Instantiate でPublisherとSubscriberを生成しながらInjectもしてもらう
Publisherでメッセージを送ればSubscriberが反応してDebugLogが表示される

めちゃめちゃシンプルですがこのコードだけでイベントの送受信ができました。

MyEventというものをもう少し現実味がある

public class LogEvent
{
    public string logMessage;
    public ErrorType errorType;
}

や

// 弾が命中したとき
public class BulletHitEvent
{
    public Enemy enemy; // 命中した敵
    public int damage; // あたったときのダメージ量
}

にして、このイベントを送受信出来るようにします。

// まずはイベント登録
// どこかのSceneContext
public class SceneContextInstaller : MonoInstaller
{
	public override void InstallBindings()
	{
		var option = Container.BindMessagePipe();

		// BindMessageBrokerでイベント登録
		Container.BindMessageBroker<LogEvent>(option);
		Container.BindMessageBroker<BulletHitEvent>(option);
	}
}

実際にイベントを送受信するクラス

// 弾クラス
public class Bullet
{
    // Zenjectが勝手にInjectしてくれる
    [Inject] IPublisher<BulletHitEvent> _bulletHitEvent;
    [Inject] IPublisher<LogEvent> _logEvent; 

    // 敵にあたったとき呼び出される
    public void Hit(Enemy enemy)
    {
        _bulletHitEvent.Publish(new BulletHitEvent { enemy = enemy, damage = 10 };
    }

    // なにか致命的なエラーが起きたときなど
    public void NanrakanoError()
    {
        _logEvent.Publish(new LogEvent 
            { 
                 logMessage = "何らかのエラーが起きました", 
                 errorType = ErrorType.Error 
            };
    }
}

....

// どこかのSceneでログを受け取る
public class Scene
{
    // Zenjectが勝手にInjectしてくれる
    [Inject] ISubscriber<BulletHitEvent> _bulletHitEvent;
    [Inject] ISubscriber<LogEvent> _logEvent; 

    public void Setup()
    {
      // Subscribeしてイベントを受け取る
      _bulletHitEvent.Subscribe(....);
      _logEvent.Subscribe(....);
    }
}

などなど..

少しずつコードに組み込んでいくことで
イベント駆動を使用する場面も徐々に思い浮かんでいくかと思います

GlobalMessagePipeでメッセージを送受信する

Zenjectを使用してMessagePipeを利用するのでイベントの範囲もZenjectがInject出来る範囲と同一である。
と考えられます。
つまりSceneContextがイベントが送受信できる範囲。

SceneContextによらずプロジェクト全体でイベントを送受信できるようにする場合はProjectContext内のInstallerでBindMessageBrokerを使用すると良いということになります。

そしてもう少し手軽にメッセージの送受信を出来るようGlobalMessagePipeを使用してみます。

GlobalMessagePipeとはその名の通りグローバル空間で使用できるものです。

using Zenject;
using MessagePipe;

namespace XXX
{
	// ProjectContext.Prefabにこのスクリプトをアタッチ
	public class ProjectContextInstaller : MonoInstaller
	{
		public override void InstallBindings()
		{
			var option = Container.BindMessagePipe();

			// LogEventをProjectContextに登録。これでどこでもLogEventが投げられるようになる
			Container.BindMessageBroker<LogEvent>(option);
			
			// GlobalMessagePipeを使用する前にSetProviderに設定する必要がある
			GlobalMessagePipe.SetProvider(Container.AsServiceProvider());
		}
	}
}

これでGlobalMessagePipeが使用可能になります。
使用するためにはGlobalMessagePipeにDIContainerのServiceProviderを登録する必要があるのですが、ここで登録するのがProjectContext

ProjectContextはシーンによらず生きているものなのでGlobalMessagePipeに登録するものとしては適切かと考えました。

登録した後はGlobalMessagePipeの静的メソッドで気軽にメッセージの送受信ができます。

// Manager的な人がゲーム全体で発行されたLogEventを受信する
public class Manager : Monobehaviour
{
    public void Awake()
    {
        // GlobalMessagePipeから直接LogEventのSubscriberを取得できる。そして即購読
        var subscriber = GlobalMessagePipe.GetSubscriber<LogEvent>();
        subscriber.Subscribe(ev => 
        {
            // コンソールに出したり、通信でログサーバーに送ったり
        });
    }
}

// バトルシーン
public class BattleScene
{
    public void NanrakanoError()
    {
        // 同じようにPublisherも直接取得して即時イベント発行
        var publisher = GlobalMessagePipe.GetPublisher<LogEvent>();
        _logEvent.Publish(new LogEvent 
            { 
                 logMessage = "何らかのエラーが起きました", 
                 errorType = ErrorType.Error 
            };
    }
}

これで更に気軽にメッセージの送受信が出来るようになりました。
イベントは場所を気にせず瞬間的に発行したいことがあるので割とこちらのほうが実際には使うケースが多いのではないでしょうか

終わりに

Disposeやフィルター機能などその他便利機能については取り上げていません。
メッセージを送受信するだけではなくMessagePipeに備わっている機能を使いこなすことで更にゲーム開発効率の向上が出来ると思います。

また実際に使用して気づいたことや便利な内容は記事にしていきます。

次 Disopose周りについての記事