static void Main(string[] args) { Console.WriteLine("Hello World!"); //启动服务端，正常逻辑是在另一个程序 RPCServer.RpcHandle(); //实例化客户端 var rpcClient = new RPCClient(); string message = $"消息id:{new Random().Next(1, 1000)}"; Console.WriteLine($"【客服端】RPC请求中，{message}"); //向服务端发送消息，等待回复 var response = rpcClient.Call(message); Console.WriteLine("【客服端】收到回复响应:{0}", response); rpcClient.Close(); Console.ReadKey(); }
测试效果：
z执行完，客服端close后，可以接着自己的下一步业务处理。
总结以上便是RabbitMQ的6中模式在.net core中实际使用，其中(1)简单队列，(2)工作队列,(4)路由模式,(6)RPC模式的交换机类型都是direct，(3)发布订阅的交换机是fanout，(5)topics的交换机是topic。正常场景用的是direct，默认交换机也是direct类型的，推荐用(4)路由模式，因为指定交换机名比起默认的交换机会容易扩展场景，其他的交换机看业务场景所需使用。
下面位置可以看到交换机类型，amq.开头那几个是内置的，避免交换机过多可以直接使用。
到此这篇关于运用.net core中实例讲解RabbitMQ的文章就介绍到这了,更多相关.net core RabbitMQ内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
您可能感兴趣的文章: