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) {

    }
}