在Akka.Net的官方文档中可以找到关于如何使用ReadJournalFor的PersistenceQuery的详细说明。下面是一个简单的代码示例：

using System;
using Akka.Actor;
using Akka.Configuration;
using Akka.Persistence.Query;
using Akka.Persistence.Query.Sql;

namespace Akka.Persistence.QueryDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            // 创建ActorSystem
            var config = ConfigurationFactory.ParseString(@"
                akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
                akka.persistence.journal.sql-server.connection-string = ""Server=(localdb)\\mssqllocaldb;Database=JournalDb;Trusted_Connection=True;""
                akka.persistence.query.journal.sql-server.connection-string = ""Server=(localdb)\\mssqllocaldb;Database=JournalDb;Trusted_Connection=True;""
                akka.actor.provider = ""Akka.Actor.LocalActorRefProvider""");
            var system = ActorSystem.Create("query-demo", config);

            // 创建ReadJournal
            var readJournal = PersistenceQuery.GetReadJournalFor(system);

            // 运行查询
            readJournal.EventsByTag("tag1")
                .RunWith(new MySink(), system.Materializer);

            // 关闭ActorSystem
            Console.ReadKey();
            system.Terminate().Wait();
        }
    }

    public class MySink : ISubscriber
    {
        public void OnComplete()
        {
            Console.WriteLine("查询完成");
        }

        public void OnError(Exception ex)
        {
            Console.WriteLine("查询错误：" + ex.Message);
        }

        public void OnNext(EventEnvelope envelope)
        {
            Console.WriteLine($"查询到匹配的数据：{envelope.PersistenceId}, {envelope.SequenceNr}, {envelope.Event}");
        }

        public void OnSubscribe(ISubscription subscription)
        {
            Console.WriteLine("开始查询");
            subscription.Request(10);
        }
    }
}

以上示例代码中使用了Akka.Net的SqlReadJournal和EventsByTag方法来进行持久化的查询，使用MySink来订阅查询结果并输出到控制台。你可以在