com.alibaba.dubbo.common.URL.getServiceInterface()方法的使用及代码示例

x33g5p2x  于2022-01-31 转载在 其他  
字(11.3k)|赞(0)|评价(0)|浏览(110)

本文整理了Java中com.alibaba.dubbo.common.URL.getServiceInterface()方法的一些代码示例，展示了URL.getServiceInterface()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。URL.getServiceInterface()方法的具体详情如下：
包路径：com.alibaba.dubbo.common.URL
类名称：URL
方法名：getServiceInterface

URL.getServiceInterface介绍

暂无

代码示例

代码示例来源：origin: liuyangming/ByteTCC

public Result providerInvoke(Invoker<?> invoker, Invocation invocation) throws RpcException, RemotingException {
  String interfaceClazz = RpcContext.getContext().getUrl().getServiceInterface();
  boolean participantFlag = TransactionParticipant.class.getName().equals(interfaceClazz);
  boolean xaResourceFlag = XAResource.class.getName().equals(interfaceClazz);
  boolean coordinatorFlag = RemoteCoordinator.class.getName().equals(interfaceClazz);
  if (participantFlag == false && xaResourceFlag == false && coordinatorFlag == false) {
    return this.providerInvokeForSVC(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_RESOURCE_START)) {
    return this.providerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_IDENTIFIER)) {
    return this.providerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_APPLICATION)) {
    return this.providerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_REMOTEADDR)) {
    return this.providerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_REMOTENODE)) {
    return this.providerInvokeForKey(invoker, invocation);
  } else {
    return this.providerInvokeForTCC(invoker, invocation);
  }
}

代码示例来源：origin: liuyangming/ByteTCC

public Result consumerInvoke(Invoker<?> invoker, Invocation invocation) throws RpcException, RemotingException {
  String interfaceClazz = RpcContext.getContext().getUrl().getServiceInterface();
  boolean participantFlag = TransactionParticipant.class.getName().equals(interfaceClazz);
  boolean xaResourceFlag = XAResource.class.getName().equals(interfaceClazz);
  boolean coordinatorFlag = RemoteCoordinator.class.getName().equals(interfaceClazz);
  if (participantFlag == false && xaResourceFlag == false && coordinatorFlag == false) {
    return this.consumerInvokeForSVC(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_RESOURCE_START)) {
    return this.consumerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_IDENTIFIER)) {
    return this.consumerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_APPLICATION)) {
    return this.consumerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_REMOTEADDR)) {
    return this.consumerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_REMOTENODE)) {
    return this.consumerInvokeForKey(invoker, invocation);
  } else {
    return this.consumerInvokeForTCC(invoker, invocation);
  }
}

代码示例来源：origin: liuyangming/ByteTCC

public Result consumerInvoke(Invoker<?> invoker, Invocation invocation) throws RpcException, RemotingException {
  String interfaceClazz = RpcContext.getContext().getUrl().getServiceInterface();
  boolean participantFlag = TransactionParticipant.class.getName().equals(interfaceClazz);
  boolean xaResourceFlag = XAResource.class.getName().equals(interfaceClazz);
  boolean coordinatorFlag = RemoteCoordinator.class.getName().equals(interfaceClazz);
  if (participantFlag == false && xaResourceFlag == false && coordinatorFlag == false) {
    return this.consumerInvokeForSVC(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_RESOURCE_START)) {
    return this.consumerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_IDENTIFIER)) {
    return this.consumerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_APPLICATION)) {
    return this.consumerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_REMOTEADDR)) {
    return this.consumerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_REMOTENODE)) {
    return this.consumerInvokeForKey(invoker, invocation);
  } else {
    return this.consumerInvokeForTCC(invoker, invocation);
  }
}

代码示例来源：origin: liuyangming/ByteTCC

public Result providerInvoke(Invoker<?> invoker, Invocation invocation) throws RpcException, RemotingException {
  String interfaceClazz = RpcContext.getContext().getUrl().getServiceInterface();
  boolean participantFlag = TransactionParticipant.class.getName().equals(interfaceClazz);
  boolean xaResourceFlag = XAResource.class.getName().equals(interfaceClazz);
  boolean coordinatorFlag = RemoteCoordinator.class.getName().equals(interfaceClazz);
  if (participantFlag == false && xaResourceFlag == false && coordinatorFlag == false) {
    return this.providerInvokeForSVC(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_RESOURCE_START)) {
    return this.providerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_IDENTIFIER)) {
    return this.providerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_APPLICATION)) {
    return this.providerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_REMOTEADDR)) {
    return this.providerInvokeForKey(invoker, invocation);
  } else if (StringUtils.equals(invocation.getMethodName(), KEY_XA_GET_REMOTENODE)) {
    return this.providerInvokeForKey(invoker, invocation);
  } else {
    return this.providerInvokeForTCC(invoker, invocation);
  }
}

代码示例来源：origin: liuyangming/ByteTCC

String interfaceClazz = RpcContext.getContext().getUrl().getServiceInterface();
boolean participantFlag = TransactionParticipant.class.getName().equals(interfaceClazz);
boolean xaResourceFlag = XAResource.class.getName().equals(interfaceClazz);

代码示例来源：origin: liuyangming/ByteTCC

String interfaceClazz = RpcContext.getContext().getUrl().getServiceInterface();
boolean participantFlag = TransactionParticipant.class.getName().equals(interfaceClazz);
boolean xaResourceFlag = XAResource.class.getName().equals(interfaceClazz);

代码示例来源：origin: com.alibaba/dubbo-rpc-api

private String normallizeMock(String mock) {
  if (mock == null || mock.trim().length() == 0) {
    return mock;
  } else if (ConfigUtils.isDefault(mock) || "fail".equalsIgnoreCase(mock.trim()) || "force".equalsIgnoreCase(mock.trim())) {
    mock = url.getServiceInterface() + "Mock";
  }
  if (mock.startsWith(Constants.FAIL_PREFIX)) {
    mock = mock.substring(Constants.FAIL_PREFIX.length()).trim();
  } else if (mock.startsWith(Constants.FORCE_PREFIX)) {
    mock = mock.substring(Constants.FORCE_PREFIX.length()).trim();
  }
  return mock;
}

代码示例来源：origin: hutai123/dubbox

protected void doSubscribe(URL url, NotifyListener listener) {
  if (Constants.ANY_VALUE.equals(url.getServiceInterface())) {
    admin = true;
  }
  broadcast(Constants.SUBSCRIBE + " " + url.toFullString());
  synchronized (listener) {
    try {
      listener.wait(url.getParameter(Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT));
    } catch (InterruptedException e) {
    }
  }
}

代码示例来源：origin: hutai123/dubbox

protected void doSubscribe(URL url, NotifyListener listener) {
  if (Constants.ANY_VALUE.equals(url.getServiceInterface())) {
    admin = true;
  }
  broadcast(Constants.SUBSCRIBE + " " + url.toFullString());
  synchronized (listener) {
    try {
      listener.wait(url.getParameter(Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT));
    } catch (InterruptedException e) {
    }
  }
}

代码示例来源：origin: net.jahhan/dubbo-registry-multicast

protected void doSubscribe(URL url, NotifyListener listener) {
  if (Constants.ANY_VALUE.equals(url.getServiceInterface())) {
    admin = true;
  }
  broadcast(Constants.SUBSCRIBE + " " + url.toFullString());
  synchronized (listener) {
    try {
      listener.wait(url.getParameter(Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT));
    } catch (InterruptedException e) {
    }
  }
}

代码示例来源：origin: com.alibaba/dubbo-registry-multicast

@Override
protected void doSubscribe(URL url, NotifyListener listener) {
  if (Constants.ANY_VALUE.equals(url.getServiceInterface())) {
    admin = true;
  }
  broadcast(Constants.SUBSCRIBE + " " + url.toFullString());
  synchronized (listener) {
    try {
      listener.wait(url.getParameter(Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT));
    } catch (InterruptedException e) {
    }
  }
}

代码示例来源：origin: com.alibaba/dubbo

private String toServicePath(URL url) {
  String name = url.getServiceInterface();
  if (Constants.ANY_VALUE.equals(name)) {
    return toRootPath();
  }
  return toRootDir() + URL.encode(name);
}

代码示例来源：origin: remoting/dubbox

private String toServicePath(URL url) {
  String name = url.getServiceInterface();
  if (Constants.ANY_VALUE.equals(name)) {
    return toRootPath();
  }
  return toRootDir() + URL.encode(name);
}

代码示例来源：origin: com.alibaba/dubbo-registry-multicast

@Override
protected void doUnsubscribe(URL url, NotifyListener listener) {
  if (!Constants.ANY_VALUE.equals(url.getServiceInterface())
      && url.getParameter(Constants.REGISTER_KEY, true)) {
    unregister(url);
  }
  broadcast(Constants.UNSUBSCRIBE + " " + url.toFullString());
}

代码示例来源：origin: com.alibaba/dubbo

@SuppressWarnings({"unchecked", "rawtypes"})
public JValidator(URL url) {
  this.clazz = ReflectUtils.forName(url.getServiceInterface());
  String jvalidation = url.getParameter("jvalidation");
  ValidatorFactory factory;
  if (jvalidation != null && jvalidation.length() > 0) {
    factory = Validation.byProvider((Class) ReflectUtils.forName(jvalidation)).configure().buildValidatorFactory();
  } else {
    factory = Validation.buildDefaultValidatorFactory();
  }
  this.validator = factory.getValidator();
}

代码示例来源：origin: com.alibaba/dubbo

@Override
protected void doUnsubscribe(URL url, NotifyListener listener) {
  if (!Constants.ANY_VALUE.equals(url.getServiceInterface())
      && url.getParameter(Constants.REGISTER_KEY, true)) {
    unregister(url);
  }
  broadcast(Constants.UNSUBSCRIBE + " " + url.toFullString());
}

代码示例来源：origin: hutai123/dubbox

@SuppressWarnings({ "unchecked", "rawtypes" })
public JValidator(URL url) {
  this.clazz = ReflectUtils.forName(url.getServiceInterface());
  String jvalidation = url.getParameter("jvalidation");
  ValidatorFactory factory;
  if (jvalidation != null && jvalidation.length() > 0) {
    factory = Validation.byProvider((Class)ReflectUtils.forName(jvalidation)).configure().buildValidatorFactory();
  } else {
    factory = Validation.buildDefaultValidatorFactory();
  }
  this.validator = factory.getValidator();
}

代码示例来源：origin: net.jahhan/dubbo-registry-multicast

protected void doUnsubscribe(URL url, NotifyListener listener) {
  if (! Constants.ANY_VALUE.equals(url.getServiceInterface())
      && url.getParameter(Constants.REGISTER_KEY, true)) {
    unregister(url);
  }
  broadcast(Constants.UNSUBSCRIBE + " " + url.toFullString());
}

代码示例来源：origin: net.jahhan/dubbo-filter-validation

@SuppressWarnings({ "unchecked", "rawtypes" })
public JValidator(URL url) {
  this.clazz = ReflectUtils.forName(url.getServiceInterface());
  String jvalidation = url.getParameter("jvalidation");
  ValidatorFactory factory;
  if (jvalidation != null && jvalidation.length() > 0) {
    factory = Validation.byProvider((Class) ReflectUtils.forName(jvalidation)).configure()
        .buildValidatorFactory();
  } else {
    factory = Validation.buildDefaultValidatorFactory();
  }
  this.validator = factory.getValidator();
}

代码示例来源：origin: hutai123/dubbox

protected void doUnsubscribe(URL url, NotifyListener listener) {
  if (! Constants.ANY_VALUE.equals(url.getServiceInterface())
      && url.getParameter(Constants.REGISTER_KEY, true)) {
    unregister(url);
  }
  broadcast(Constants.UNSUBSCRIBE + " " + url.toFullString());
}

内容来源于网络，如有侵权，请联系作者删除！

URL

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    URL类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com