import retrofit2.http.GET;
import retrofit2.http.Path;
-/**
- * @author hu.rui
- *
- */
-
@ServiceHttpEndPoint(serviceName = "animals", serviceVersion = "v1")
public interface AnimalServiceClient {
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
******************************************************************************/
-/**
- *
- */
package org.onap.msb.sdk.example.client;
import java.io.IOException;
import org.onap.msb.sdk.example.common.Animal;
import org.onap.msb.sdk.httpclient.RetrofitServiceCreater;
import org.onap.msb.sdk.httpclient.conf.HttpClientConf;
-import org.onap.msb.sdk.httpclient.msb.MSBServiceWrapperClient;
+import org.onap.msb.sdk.httpclient.msb.MSBServiceClient;
public class ExampleClient {
int MSB_Port=10081;
HttpClientConf globalHttpClientConf = new HttpClientConf();
- MSBServiceWrapperClient msbClient = new MSBServiceWrapperClient(MSB_IP, MSB_Port);
+ MSBServiceClient msbClient = new MSBServiceClient(MSB_IP, MSB_Port);
RetrofitServiceCreater retrofitServiceCreater =
new RetrofitServiceCreater(globalHttpClientConf, msbClient);
package org.onap.msb.sdk.example.server;
import org.onap.msb.sdk.example.server.resources.AnimalResource;
-import org.onap.msb.sdk.httpclient.msb.MSBServiceWrapperClient;
+import org.onap.msb.sdk.httpclient.msb.MSBServiceClient;
import io.dropwizard.Application;
import io.dropwizard.setup.Environment;
environment.jersey().register(new AnimalResource());
- MSBServiceWrapperClient msbClient = new MSBServiceWrapperClient(MSB_IP, MSB_Port);
+ MSBServiceClient msbClient = new MSBServiceClient(MSB_IP, MSB_Port);
MsbHelper helper = new MsbHelper(msbClient);
helper.registerMsb();
import org.jvnet.hk2.annotations.Service;
import org.onap.msb.sdk.discovery.entity.MicroServiceInfo;
import org.onap.msb.sdk.discovery.entity.Node;
-import org.onap.msb.sdk.httpclient.msb.MSBServiceWrapperClient;
+import org.onap.msb.sdk.httpclient.msb.MSBServiceClient;
-/**
- * @author hu.rui
- *
- */
-@Service
public class MsbHelper {
- private MSBServiceWrapperClient msbClient;
+ private MSBServiceClient msbClient;
-
-
- public MsbHelper(MSBServiceWrapperClient msbClient) {
+ public MsbHelper(MSBServiceClient msbClient) {
super();
this.msbClient = msbClient;
}
private Set<NodeInfo> nodes;
- // 状态 0:不可用 1:可用,预留
+ //Reserved
private String status = "1";
public Set<NodeInfo> getNodes() {
import org.onap.msb.sdk.httpclient.conf.HttpClientConf;
import org.onap.msb.sdk.httpclient.handler.RetrofitServiceHandlerContext;
import org.onap.msb.sdk.httpclient.handler.RetrofitServiceHandlerFactory;
-import org.onap.msb.sdk.httpclient.msb.MSBServiceWrapperClient;
+import org.onap.msb.sdk.httpclient.msb.MSBServiceClient;
-/**
- * @author 10071214
- *
- */
public class RetrofitServiceCreater {
private RetrofitServiceHandlerFactory factory = new RetrofitServiceHandlerFactory();
- private MSBServiceWrapperClient msbClient;
+ private MSBServiceClient msbClient;
public RetrofitServiceCreater(HttpClientConf globalHttpClientConf,
- MSBServiceWrapperClient msbClient) {
+ MSBServiceClient msbClient) {
RetrofitServiceHandlerContext.setGlobalHttpClientConf(globalHttpClientConf);
this.msbClient = msbClient;
import com.fasterxml.jackson.annotation.JsonProperty;
-/**
- * @author 10071214
- *
- */
public class HttpClientConf {
@JsonProperty
import org.onap.msb.sdk.httpclient.convert.IConverterFactoryBuilder;
import org.onap.msb.sdk.httpclient.lb.ILoadBalanceStrategy;
import org.onap.msb.sdk.httpclient.metric.MetricManager;
-import org.onap.msb.sdk.httpclient.msb.MSBServiceWrapperClient;
+import org.onap.msb.sdk.httpclient.msb.MSBServiceClient;
/**
private HttpClientConf httpClientConf;
- private MSBServiceWrapperClient msbClient;
+ private MSBServiceClient msbClient;
- public MSBServiceWrapperClient getMsbClient() {
+ public MSBServiceClient getMsbClient() {
return msbClient;
}
- public void setMsbClient(MSBServiceWrapperClient msbClient) {
+ public void setMsbClient(MSBServiceClient msbClient) {
this.msbClient = msbClient;
}
import org.onap.msb.sdk.httpclient.handler.impl.MetricmanagerBuilder;
import org.onap.msb.sdk.httpclient.handler.impl.RetrofitHandlerContextBuilder;
import org.onap.msb.sdk.httpclient.handler.impl.ServiceHttpEndPointBeanObjectBuilder;
-import org.onap.msb.sdk.httpclient.msb.MSBServiceWrapperClient;
+import org.onap.msb.sdk.httpclient.msb.MSBServiceClient;
import com.google.common.collect.Lists;
public InvocationHandler buildInvocationHandler(Class<?> retrofitSrvInterfaceClazz,
ServiceHttpEndPointBeanObject serviceHttpEndPointBeanObject, HttpClientConf httpClientConf,
- MSBServiceWrapperClient msbClient) {
+ MSBServiceClient msbClient) {
RetrofitServiceHandlerContext ctx = new RetrofitServiceHandlerContext();
ctx.setRetrofitSrvInterfaceClazz(retrofitSrvInterfaceClazz);
import org.slf4j.LoggerFactory;
-public class MSBServiceWrapperClient {
+public class MSBServiceClient {
- private static final Logger logger = LoggerFactory.getLogger(MSBServiceWrapperClient.class);
+ private static final Logger logger = LoggerFactory.getLogger(MSBServiceClient.class);
private String msbSvrAddress;
private MSBService msbService = new MSBService();
- private String nameSpace;
-
- public MSBServiceWrapperClient(String msbSvrIp, int msbSvrPort) {
+ public MSBServiceClient(String msbSvrIp, int msbSvrPort) {
super();
this.msbSvrAddress = msbSvrIp + ":" + msbSvrPort;
- logger.info("msb service info:msbSvrAddress:{},nameSpace:{}", this.msbSvrAddress,
- this.nameSpace);
-
+ logger.info("msb service info:msbSvrAddress:{}", this.msbSvrAddress);
}
public MicroServiceFullInfo queryMicroServiceInfo(String serviceName, String version)
throws RouteException {
-
return invokeMsb(() -> msbService.queryMicroServiceInfo(msbSvrAddress, serviceName, version));
-
-
}
private <V> V invokeMsb(Callable<V> callable) throws RouteException {
}
- /**
- * 注册微服务-默认追加方式,在msb上注册服务信息,服务的信息都可以填充在MicroServiceInfo上,包括:租户的信息等
- *
- * @param microServiceInfo 微服务注册实体类
- * @throws RouteException
- * @return MicroServiceFullInfo
- */
public MicroServiceFullInfo registerMicroServiceInfo(MicroServiceInfo msinfo)
throws RouteException {
- /**
- * 注册微服务,在msb上注册服务信息,服务的信息都可以填充在MicroServiceInfo上,包括:租户的信息等
- *
- * @param microServiceInfo 微服务注册实体类
- * @param createOrUpdate true:新增或追加更新 ,false:重新添加
- * @throws RouteException
- * @return MicroServiceFullInfo
- */
public MicroServiceFullInfo registerMicroServiceInfo(MicroServiceInfo msinfo,
boolean createOrUpdate) throws RouteException {
/**
- * @Title cancelMicroServiceInfo
- * @Description TODO(注销全部微服务)
- * @param serviceName 服务名[必填,若自定义服务名包含/,用*代替]
- * @param version 版本号[若无版本号,传空字符串]
- * @throws RouteException
- * @return RouteResult
+ * unregister all the instances of a service
*/
public RouteResult cancelMicroServiceInfo(String serviceName, String version)
throws RouteException {
/**
- * 注销单个微服务
- *
- * @param serviceName 服务名[必填,若自定义服务名包含/,用*代替]
- * @param version 版本号[若无版本号,传空字符串]
- * @param ip
- * @param port
- * @throws RouteException
- * @return RouteResult
+ * unregister the specified instance of a service
*/
public RouteResult cancelMicroServiceInfo(String serviceName, String version, String ip,
return msbSvrAddress;
}
-
-
- /**
- * 请求服务实例TTL健康检查,默认使用本租户的信息
- *
- * @param serviceName 服务名
- * @param version 版本号[若无版本号,传空字符串]
- * @param ip 实例IP
- * @param port 实例端口
- * @throws RouteException
- * @return CheckNode
- */
- public NodeAddress healthCheckbyTTL(String serviceName, String version, String ip, String port)
- throws RouteException {
-
- return invokeMsb(
- () -> msbService.healthCheckbyTTL(msbSvrAddress, serviceName, version, ip, port));
-
- }
-
-
-
}