Solon Cloud —— 服务注册与发现

说明

服务注册与发现是一种动态管理服务实例的机制，其目的是让各个服务能够及时了解其他服务的状态与位置，以便能进行相互的通讯与协作。

依赖

添加 nacos2 的依赖 org.noear:nacos2-solon-cloud-plugin。

dependencies {
    implementation platform(project(":demo-parent"))

    implementation("org.noear:solon-web")
    implementation("org.noear:solon-logging-logback")
    implementation("org.noear:solon-openapi2-knife4j")
    implementation("org.noear:nacos2-solon-cloud-plugin")
    // 使用 httputils
    implementation("org.noear:solon-net-httputils")
    
    // 使用 NamiClient
    implementation("org.noear:nami-coder-snack3")
    implementation("org.noear:nami-channel-http")

    annotationProcessor("org.mapstruct:mapstruct-processor:${mapstructVersion}")

    testImplementation("org.noear:solon-test-junit5")
}

配置

Nacos2 插件已经做了些默认值，所以我不需要过多的配置即可连接到 nacos 发现服务，如果使用了server 节点，意思是配置服务和发现服务使用同一个配置，或者单独使用solon.cloud.nacos.discovery.server配置。

solon.app:
  name: "demo-cloud-config"
  # group: "DEFAULT_GROUP" # 默认值为 DEFAULT_GROUP
  # namespace: "public" # 默认值为 public

solon.cloud.nacos:
  server: "localhost:8848"
  config:
    load: "demo-cloud-config.yml"
  # discovery:
  #   server: "localhost:8848"

服务调用

测试服务

测试服务中我们提供一个hello接口，并增加表示是从 Service01 的标识。

 package com.example.demo.solon.controller;

import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.noear.solon.annotation.Controller;
import org.noear.solon.annotation.Mapping;
import org.noear.solon.annotation.Param;

/**
 * @author airhead
 */
@Api("Demo")
@Controller
@Mapping
public class DemoController {
  @ApiOperation("hello")
  @Mapping("/hello")
  public String hello(@Param(defaultValue = "world") String name) {
    return String.format("Hello %s!, By Service01", name);
  }
}

DemoController

Solon 的 NamiClient 或者 HttpUtils 可以通过服务名来调用服务，其中NamiClient可以通过类似FeignClient的注解的方式进行使用。

package com.example.demo.solon.controller;

import com.example.demo.solon.client.DemoClient;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import java.io.IOException;
import org.noear.nami.annotation.NamiClient;
import org.noear.solon.annotation.Controller;
import org.noear.solon.annotation.Mapping;
import org.noear.solon.annotation.Param;
import org.noear.solon.net.http.HttpUtils;

/**
 * @author airhead
 */
@Api("Demo")
@Controller
@Mapping
public class DemoController {
  @NamiClient private DemoClient demoClient;

  @ApiOperation("hello")
  @Mapping("/hello")
  public String hello(@Param(defaultValue = "world") String name) {
    try {
      return HttpUtils.http("demo-cloud-service01", "/hello").data("name", name).get();
    } catch (IOException e) {
      throw new RuntimeException(e);
    }
  }

  @ApiOperation("hello2")
  @Mapping("/hello2")
  public String hello2(@Param(defaultValue = "world") String name) {
    return demoClient.hello(name);
  }
}

DemoClient

package com.example.demo.solon.client;

import org.noear.nami.annotation.NamiClient;

/**
 * @author airhead
 */
@NamiClient(name = "demo-cloud-service01")
public interface DemoClient {
  String hello(String name);
}