SmartRoute是基于Dotnet Core设计的可运行在linux和windows下的服务通讯组件，其设计理念是去中心化和零配置即可实现服务通讯集群。SmartRoute是通过消息订阅的机制实现服务与服务之间的通讯，它可以让广播网段内所有服务器上的应用自动构建通讯集群； 而通讯集群完全是SmartRoute自动构建并不需要进行任何配置或安装中间服务。通过这种全新的通讯开发方式可以让开发者更轻松和简单地构建基于服务的集群通讯应用。
## 订阅
public class Program
{
static long mCount;
public static void Main(string[] args)
{
INode node = NodeFactory.Default;
node.Open();
EventSubscriber henry = node.Register<EventSubscriber>("henry");
henry.Register<User>(OnUser);
henry.Register<Employee>(OnEmployees);
Console.Read();
}
private static void OnEmployees(Message msg, Employee emp)
{
System.Threading.Interlocked.Increment(ref mCount);
msg.Reply(Employee.GetEmployee());
}
private static void OnUser(Message msg, User user)
{
System.Threading.Interlocked.Increment(ref mCount);
msg.Reply(new User { Name = "henry" });
}
}## 订阅,发现和推送消息
public class Program
{
static long mCount;
public static void Main(string[] args)
{
INode node = NodeFactory.Default;
node.Open();
EventSubscriber ken = node.Register<EventSubscriber>("ken");
ken.Register<User>(OnUser);
ken.Register<Employee>(OnEmployees);
node.SubscriberRegisted = (n, s) =>
{
if (s.Name == "henry")
{
ken.Publish("henry", Employee.GetEmployee());
}
};
while (true)
{
Console.WriteLine(mCount);
System.Threading.Thread.Sleep(1000);
}
Console.Read();
}
private static void OnEmployees(Message msg, Employee emp)
{
System.Threading.Interlocked.Increment(ref mCount);
msg.Reply(Employee.GetEmployee());
}
private static void OnUser(Message msg, User user)
{
msg.Reply(new User { Name = "key" });
System.Threading.Interlocked.Increment(ref mCount);
}
}由于很多场景需要支持同步返回消息处理，因此加入些功能的支持
Employee result = ken.Publish<Employee>("henry", Employee.GetEmployee());通过SwitchSubscriber实现多节点订阅负载处理
IList<Employee> item = mSwitchSubscriber.PublishToServicee<IList<Employee>>("henry", Employee.GetEmployee());
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent