@Data
public class IdQuery {
    //基于 validation 的注解,如果验证不通过会返回 Code.PARAM_INVALID 错误码,如果想返回自定义的错误码,message 设置如下
    @NotNull(message = BaseConstant.INVALID_CODE_PREFIX + TestCode.NAME_IS_NULL)
    @Size(min = 4,max = 20)
    private String name;

    @Min(5)@Max(99)
    private int age = 10;

    @NotNull@Size(min = 1,max= 100)
    private List<String> ids;
}

@Component("getUserInfo")
public class GetUserInfo implements Method<IdQuery,List<UserBean>> {

    // 本方法只会在 idQuery 校验成功执行
    @Override
    public List<UserBean> action(Token token,IdQuery idQuery) {
        // throw new JException(TestCode.JUST_ERROR);  //通过异常返回错误码
//         throw new JException(TestCode.JUST_ERROR,idQuery);  //通过异常返回错误码,并返回一些数据
        return idQuery.getIds().stream().map(id -> {
            UserBean userBean = new UserBean();
            userBean.setId(id);
            userBean.setAge(idQuery.getAge());
            userBean.setName(idQuery.getName());
            return userBean;
        }).collect(Collectors.toList());
    }
}

@Component("getUserInfo2")
public class GetUserInfo2 implements AsyncMethod<IdQuery,List<UserBean>> {

    // 本方法只会在 idQuery 校验成功执行
    @Override
    public Mono<List<UserBean>> action(Token token,IdQuery idQuery) {
        // throw new JException(TestCode.JUST_ERROR);  //通过异常返回错误码
//         throw new JException(TestCode.JUST_ERROR,idQuery);  //通过异常返回错误码,并返回一些数据
        return Mono.fromCallable(() -> {
                throw new JException(TestCode.JUST_ERROR,idQuery);//任何位置都可以使用来返回
                return idQuery.getIds().stream().map(id -> {
                    UserBean userBean = new UserBean();
                    userBean.setId(id);
                    userBean.setAge(idQuery.getAge());
                    userBean.setName(idQuery.getName());
                    return userBean;
                }).collect(Collectors.toList());
        });

    }
}

public class Test 
{
    @Resource
    private JrpcClient jrpcClient;

    public void test2(){
        IdQuery idQuery = new IdQuery();
        idQuery.setName("zhangsan");
        idQuery.setAge(77);
        idQuery.setIds(Lists.newArrayList("123","345"));

        Token token = new Token();

        Rsp rsp = Request.newInstance()
                .setClient(jrpcClient) //设置发送客户端
                .setServer("test")     //调用的服务名
                .setVersion("2.0")   //服务的版本号
//                .setInstance("test-111") //服务实例名,多个实例可以指定发送到对应的服务,没找到会有相应的错误码
                .setMethod("getUserInfo") //服务方法名
                .setToken(token) // 设置token ,可选 token 信息
                .setParamObj(idQuery) //请求参数对象,也可以使用 setParamJson 直接设置json字符串
                //.setOneway(true) //是否为 oneway 调用,
                //asyncSend() 得到 Single<Rsp> 对象,异步调用模式
                .send() //发送请求,这时已经得到 Rsp 对象

                .checkSuccess(); //检查 返回码,不为 SUCCESS 则抛出异常
        List<UserBean> userBeans = rsp.list(UserBean.class); //rsp中result实际为json字符串.list为将json反序列化为 List对象
        List<UserBean> userBeans1 = rsp.get(List.class,UserBean.class); //也可以使用 get 带泛型的反序列化
    }
}

@SpringBootApplication
@EnableJrpcServices
public class App {
    public static void main(String[] args) {
        SpringApplication.run(App.class, args);
    }
}

@JrpcService(server = "test", version = "1.0")
public interface TestService {

    void traceTest2(Token token, int i);

    Rsp asyncErr(Token token, String abc);

    String asyncTest(Token token, String abc);

    Mono<Void> myMethod(Token token, Object abc);

    Mono<Object> testMethod(Token token, List<String> abc);

    Mono<Rsp> traceTest(Token token, int i);

    Mono<InterfaceInfo> getServerInfo(Token token, Object obj);
}

public class ServiceTest {
    @Autowired
    private TestService testService;
}