SOFABolt官方版

SOFABolt简介

SOFABolt是一个网络通信框架，当您需要为应用程序配置远程通信服务时，可以使用它。有了这个软件，可以为各种应用的远程服务调用配置具体的方案，使应用前的数据能够同步，从而从监控平台上的多个终端获取数据，对于需要远程监控数据、监控流量变化、监控平台负载的场景非常有帮助。基于Netty软件开发，可以在sofabet中使用XML，在sofabet中使用注释，在sofabet中使用动态API，或者结合SOFARPC为开发者提供更便捷的应用通讯服务配置方案！

SOFABolt软件功能

SOFABolt的基本功能包括:

1.基本通信功能(远程处理核心)

基于网络的高效网络输入输出及线程模型的应用

连接管理(无锁连接、定期断开、自动重新连接)

基本通信模型(单向、同步、未来、回叫)

超时控制

批量拆包和批量提交处理器

和心跳空闲事件处理

2.协议框架

命令和命令处理器

编解码器处理器

心跳触发器

3.私有协议定制的实现& # 8211；RPC通信协议(pt ocol-实现)

RPC通信协议的设计

基于的反序列化灵活时序控制

处理超时请求的故障快速机制

用户处理器

双工通信

SOFABolt软件特色

SOFABolt是蚂蚁金服集团开发的基于Netty的网络通信框架。

*为了让Java程序员更专注于基于网络通信的业务逻辑的实现，而不是过分纠结于网络底层NIO的实现，处理难以调试的网络问题，Netty应运而生。

* SOFABolt的产生是为了让中间件开发者更加关注产品功能的特殊实现，而不是重复制造通信框架的子部分。

Bolt以Disney Animation-Flash命名，是一个基于Netty最佳实践的轻量级、易用、高能、可扩展的通信框架。

近年来，我们解决了微服务和消息中间件在网络通信中的诸多问题，积累了大量经验，并不断优化和完善。我们希望将总结出来的解决方案存放到基础组件SOFABolt中，让更多使用网络通信的场景统一受益。

目前，该产品已应用于SOFARPC、消息中心、分布式事务、分布式交换机、配置中心等蚂蚁中间件的多个产品中。

SOFABolt教程

开始使用SOFABoot

创建项目

1.准备环境:SOFABoot需要JDK7或JDK8，需要用Apache Maven 2.2.5或更高版本进行编译。

2.生成sofabot项目:sofabot基于Spng Boot。因此，您可以使用Spng Boot的项目生成工具来生成标准的Spng Boot项目。

3.添加sofabot依赖:生成的标准Spng Boot项目直接使用Spng父依赖，应该改为sofabot提供的父依赖。父依赖项提供并管理SOFABoot提供的各种启动程序。

以下文取代上述内容:

1.配置应用程序。应用程序。pperties是SOFABoot项目中的配置文件。在这里，您需要配置应用程序名称。

spng.application.name=AppName

2.介绍RPC启动器:

声明SOFABoot的Xsd文件:

在要使用的XML配置文件中，如下配置头文件xsd文件的声明。这样，SOFABoot定义的XML元素就可以用于开发。

定义服务接口和实现

在上发布服务

在xml文件中配置以下内容。刷新Spng上下文后，SOFABoot在上注册服务实现，通过bolt协议与客户端通信，并向注册中心发布地址等元数据(默认情况下，本地文件用作注册中心)。

客户咨询服务

在xml文件中配置以下内容。SOFABoot在刷新Spng上下文后生成RPC代理Bean personReferenceBolt。这允许您在代码中直接使用Bean进行远程调用。

运行项目

SpngBoot的引导类代码如下。上面的xml文件是使用ImportResource加载的。

输出如下:

同步

通过这一步，您已经完成了服务的发布和引用。

在非Spng环境中使用API

SOFARPC

服务发布

服务发布过程涉及三个类:RegistryConfig、ServerConfig和PviderConfig。

1.注册表配置

1、

RegistryConfig代表注册表。如上所述，服务注册表的地址和端口是127.0.0.1:2181，协议是Zookeeper。

I .配置Java服务器配置配置=新服务器配置()。设定端口(8803)。set tocol(& # 8220；博尔特& # 8221；);ServerConfig表示服务运行的容器。上面的语句使用了8803端口和bolt协议。

1、PviderConfig

PviderConfig是代表服务发布的。上面声明了服务的接口，实现了服务的运行。最后，通过导出方法发布服务。

服务参考

引用涉及两个类，即RegistryConfig和ConsumerConfig。

ConsumerConfig代表服务参考。上面声明了引用服务接口的接口和服务注册中心。最后，refer方法引用该服务，以获取该服务的远程调用的代理。

在软件中使用可扩展标记语言

XML架构

这个方法的发布和XML模式的引用服务如下。沙发:代表出版服务，沙发:代表参考服务。Sofa:绑定表示用于服务发布或引用的协议。

服务也可以通过各种协议发布，如下所示:

服务参考

其他协议也可以引用服务:

在SOFABoot中使用注释

使用注释进行服务发布/引用

除了传统的xml模式之外，它还支持在SOFABoot环境中发布和引用带注释的服务。类似于XML，我们提供了@沙发服务和@沙发引用以及@沙发服务绑定和@沙发引用绑定作为多协议。

服务发布

要发布RPC服务，您只需要@沙发服务在Bean上添加注释来指定接口和协议类型。

服务参考

对于需要引用远程服务的bean，只需在类属或方法上添加一个Reference注释。这支持bolt dubbo rest协议。

在SOFABoot中使用动态API

使用API

SOFABoot为RPC服务发布和引用提供了一套编程API。直接在代码中发布和引用RPC服务很方便。与Spng的ApplicationContextAware类似，要使用编程API，您需要首先实现ClientFactoryAware接口来获取编程组件API:

以DirectService为例，学习如何通过编程API使用clientFactory发布RPC服务:

在上面的代码中:

1.首先，ServiceClient获取对象clientFactory。

2.构造包含发布服务所需参数的ServiceParam对象，使用setInstance方法设置要发布为RPC服务的对象，使用setInteceType设置服务的接口。

3.最后，调用ServiceClient的服务方法发布RPC服务。

通过编程接口引用RPC服务的代码类似:

同样，引用一个RPC服务，代码只需要从ClientFactory获取ReferenceClient，构造一个ReferenceParam类似的发布服务，下一组服务接口，最后调用ReferenceClient的引用方法。