NetSync.Rabbitmq 1.1.0

NetSync

介绍

基于消息中间件的同步调用封装、异步消息实用封装

使用说明

using NetSync.Core;
using NetSync.Rabbitmq;
using System.Collections.Concurrent;
using System.Text;

namespace NetSync.Test
{
    internal class Program
    {
        static void Main(string[] args)
        {
            var config = new RabbitMQConfig
            {
                Address = "localhost:5672",
                User = "guest",
                Password = "guest",
                ConsumerCountPerGroup = 1,
                NewConnectionPerSend = true
            };
            var serialize = new NewtonsoftJsonNetSerialize();
            INetConnection connection = new NetRabbitMQConnection(serialize);
            connection.ConnectionEvent += Connection_ConnectionEvent;
            connection.DispatchMessageEvent += Connection_DispatchMessageEvent;
            var waitSync = new MemoryWaitSync();
            INetSync<MessageBasic, MessageBasic> netSync = new TestNetSync(connection, waitSync);
            connection.InitAsync(config).ConfigureAwait(false).GetAwaiter().GetResult();
            var subscribeInfos = new List<SubscribeInfo>()
            {
                new SubscribeInfo()
                {
                    Topic = "",
                    Group = "test1"
                },
                 new SubscribeInfo()
                {
                    Topic = "",
                    Group = "test2"
                },
                  new SubscribeInfo()
                {
                    Topic = "111",
                    Group = "test2"
                }
            };
            connection.SubscribeAsync(subscribeInfos).GetAwaiter().GetResult();
            connection.UnsubscribeAsync(subscribeInfos).GetAwaiter().GetResult();
            connection.PublishAsync("EapRmsQueue/EQP-001", Encoding.UTF8.GetBytes("test")).GetAwaiter().GetResult();
            //var key = Guid.NewGuid().ToString();
            //waitSync.WaitAsync<string>(key, 10).ConfigureAwait(false).GetAwaiter().GetResult();
            Console.ReadKey();
            Console.WriteLine("Hello, World!");
        }

        private static void Connection_DispatchMessageEvent(object? sender, DispatchEventArgs e)
        {
            Console.WriteLine($"数据是否已处理：{e.IsHandled}");
        }

        private static void Connection_ConnectionEvent(object? sender, ConnectionEventArgs e)
        {
            Console.WriteLine($"{e.ConncetionType.ToString()}:{e.Message}");
        }
    }

    public class TestNetSync : NetSyncAbstract<MessageBasic, MessageBasic>
    {
        public TestNetSync(INetConnection connection, IWaitSync waitSync) : base(connection, waitSync)
        {
        }

        public override Func<MessageBasic, MessageBasic, string> MsgIdFunc => (req, rep) =>
        {
            return req == null ? rep.Id : req.Id;
        };

    }
}