簡介
一站式分布式服務治理中台,可以了解為微服務架構支援套件,5個服務包合計40m大小,超輕量級。
功能相當于:consul + rabbitmq + elk + prometheus + openFaas + quartz +等等并有機結合在一起。
對 k8s 友好,支援 ip 漂移、支援 k8s svc 映射。簡單工作,早點下班。
架構與構件
使用
配置
pom.xml / mevan 配置
<!-- 用戶端版本 -->
<dependency>
<groupId>org.noear</groupId>
<artifactId>water.client</artifactId>
<version>2.13.1</version>
</dependency>
<!-- solon cloud 內建版本 (也可用于 Spring Boot 項目) -->
<dependency>
<groupId>org.noear</groupId>
<artifactId>water-solon-cloud-plugin</artifactId>
<version>2.6.0</version>
</dependency>
app.yml / 配置說明
solon.app:
name: "wateradmin"
group: "water"
solon.cloud.water:
server: "waterapi:9371" #WATER服務位址
config:
load: "test.yml" #預設加載的配置
log:
default: "water_log_admin" #預設日志記錄器
代碼
public class DemoApp {
public void main(String[] args) {
SolonApp app = Solon.start(DemoApp.class, args);
//監控服務:之:添加接口性能記錄(一般這個過濾器寫成獨立類)
Logger log = LoggerFactory.getLogger(DemoApp.class);
app.filter((ctx, chain) -> {
//1.開始計時(用于計算響應時長)
long start = System.currentTimeMillis();
try {
chain.doFilter(ctx);
} catch (Throwable e) {
//2.順帶記錄個異常
log.error("{}",e);
} finally {
//3.獲得接口響應時長
long milliseconds = System.currentTimeMillis() - start;
CloudClient.metric().addMeter(Solon.cfg().appName(), "path", ctx.pathNew(), milliseconds);
}
});
}
}
@Configuration
public class DemoConfig {
@Bean
public DataSource db1(@CloudConfig("demoDb") HikariDataSource ds) {
//配置一個資料源
return ds;
}
@Bean
public I18nBundleFactory i18nBundleFactory(){
//将國際化服務,切換為雲端接口
return new CloudI18nBundleFactory();
}
}
@Slf4j
@Controller
public class DemoController{
@CloudConfig(name = "demoDb", autoRefreshed = true) //配置服務的功能(注解模式)
DbContext demoDb;
@NamiClient //RPC服務發現的功能(注解模式)
RockService rockService;
@Mapping("/")
public void test(){
//日志服務:寫個日志
log.info("你好,日志服務"); //(content)
TagsMDC.tag0("demo");
log.error("{}\r\n{}","test","你好,日志服務"); //(tag,summary,content)
//配置服務:使用配置的資料庫上下文進行查詢
Map map = demoDb.table("water_reg_service").limit(1).selectMap("*");
//消息服務:發送消息
CloudClient.event().publish(new Event("demo.test", "{\"order_id\":1}")); //(非注解模式)
//Rpc發現服務:調用Rpc接口
AppModel app = rockService.getAppById(12);
}
}
//消息訂閱:訂閱消息并處理(根據:topic 進行訂閱)
@Slf4j
@CloudEvent("demo.test")
public class Event_demo_test implements CloudEventHandler {
@Override
public boolean handle(Event event) throws Exception {
//處理消息...
log.info("我收到消息:" + event.content());
return true;
}
}
//配置訂閱:關注配置的實時更新
@CloudConfig("demoDb")
public class TestConfigHandler implements CloudConfigHandler {
@Override
public void handle(Config config) {
}
}
//分布式任務
@CloudJob(name = "demo_test", cron7x = "0 1 * * * ?")
public class Job_test implements CloudJobHandler {
@Override
public void handle(Context ctx) throws Throwable {
//處理任務...
log.info("我被排程了");
}
}
管理界面
告警專用用戶端
告警工具
日志查詢
消息總線
服務監控
配置管理
開發助手