JarCasting
QQ交流群：22200020
Water for java （水孕育万物...）
为中小量级项目，提供服务开发和治理的整体解决方案（可以理解为微服务架构套件）。
开始
了解框架与构件
| 组件 | 说明 |
|---|---|
| org.noear:water.client | 框架：Water 客户端 |
| org.noear:water-solon-plugin | 框架：Water 客户端 for solon |
| org.noear:waterapi | 构建：Water 服务端 |
| org.noear:watersev | 构建：Water 后台服务（消息派发；定时任务；服务检测...） |
| org.noear:wateradmin | 构建：Water 控制台 |
| org.noear:waterpaas | 构建：Water PaaS 服务，提供轻量级接口服务 |
| org.noear:waterraas | 构建：Water RaaS 服务，提供轻量级规则计算服务 |
控制台演示站
地址： http://water.noear.org （账号：demo ；密码：demo ）
(一) 使用
配置
- pom.xml / mevan 配置
<!-- 客户端版本 -->
<dependency>
<groupId>org.noear</groupId>
<artifactId>water.client</artifactId>
<version>2.1.1</version>
</dependency>
<!-- solon cloud 集成版本 -->
<dependency>
<groupId>org.noear</groupId>
<artifactId>water-solon-plugin</artifactId>
<version>1.4.2</version>
</dependency>
- application.yml / 配置说明
solon.app:
name: "wateradmin"
group: "water"
solon.cloud.water:
server: water #WATER服务地址
config:
load: "test.properties" #默认加载的配置
event:
receive: "api.water.io" #当前服务主机地址（一般设为外网地址；用于订阅业务消息用）
#receive: "@water_admin_host" #如果域名会变，可通过配置指定（@开头，表示从water配置服务获取）
log:
default: "water_log_admin" #默认日志记录器
代码
public class DemoApp{
public void main(String[] args){
Solon app = Solon.start(args);
//监控服务：之：添加接口性能记录
app.before("**",XMethod.HTTP,-1,(c)->{
c.attrSet("_timecount", new Timecount().start());
});
app.after("**", XMethod.HTTP,(c)->{
Timecount timecount = c.attr("_timecount", null);
if (timecount == null || c.status() == 404) {
return;
}
String node = WaterAdapter.global().localHost();
long times = timecount.stop().milliseconds();
WaterClient.Track.track("water-demo", "path", c.path(), times, node);
});
}
}
@Slf4j
@Controller
class demo{
@CloudConfig("water") //配置服务的功能（注解模式）
DbContext waterDb;
@NamiClient //RPC服务发现的功能（注解模式）
RockRpc rock;
@Mapping("/")
public void test(){
//日志服务：写个日志
log.info("你好，日志服务"); //(content)
TagsMDC.tag0("demo");
log.error("{}\r\n{}","test","你好，日志服务"); //(tag,summary,content)
//配置服务：使用配置的数据库上下文进行查询
var map = waterDb.table("bcf_user").limit(1).select("*").getMap();
//消息服务：发送消息
CloudClient.event().publish(new Event("test.order.start", "{\"order_id\":1}")); //（非注解模式）
//PaaS服务：调用PaaS接口
WaterProxy.paas("water/test", null);
//Rpc发现服务：调用Rpc接口
AppModel app = rock.getAppById(12);
}
}
//消息订阅：订阅消息并处理（根据：topic 进行订阅）
@CloudEvent("test.order.end")
public class msg_updatecache implements CloudEventHandler {
@Override
public boolean handler(Event event) throws Exception {
//处理消息...
}
}
//配置订阅：关注配置的实时更新
@CloudConfig("water")
public class TestConfigHandler implements CloudConfigHandler {
@Override
public void handler(Config config) {
}
}
（二）代码示例
https://gitee.com/noear/water_demo
（三）部署
参考《DEP.md》
（四）架构说明
相关材料未准备好...
管理界面预览
- 报警专用客户端
- 管理小工具
- 日志查询
- 消息中心管理
- 服务监控
- 配置管理
- PaaS管理后台
- 开发者小工具
