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

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

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

URL.getHost介绍

暂无

代码示例

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

URL invokerUrl = invoker.getUrl();
RemoteAddr remoteAddr = new RemoteAddr();
remoteAddr.setServerHost(invokerUrl.getHost());
remoteAddr.setServerPort(invokerUrl.getPort());

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

public int compareTo(Configurator o) {
  if (o == null) {
    return -1;
  }
  return getUrl().getHost().compareTo(o.getUrl().getHost());
}

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

public int compareTo(Configurator o) {
  if (o == null) {
    return -1;
  }
  return getUrl().getHost().compareTo(o.getUrl().getHost());
}

代码示例来源:origin: io.eventcenter/ec-remote-dubbo

boolean filterWithDevMode(URL url){
  if(!devMode){
    return true;
  }
  final String remoteAddress = new StringBuilder(url.getHost()).append(":").append(url.getPort()).toString();
  if(remoteAddress.contains(LOCAL_IP1) || remoteAddress.contains(LOCAL_IP2)) {
    return true;
  }
  return remoteAddress.contains(NetUtils.getLocalHost());
}

代码示例来源:origin: io.eventcenter/ec-remote-dubbo

String createAddress(URL url){
  if(copySendUnderSameVersion) {
    return new StringBuilder(url.getHost()).append(":").append(url.getPort()).toString();
  }
  return url.getParameter("version");
}

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

@Override
public InetSocketAddress getRemoteAddress() {
  if (client == null) {
    return InetSocketAddress.createUnresolved(url.getHost(), url.getPort());
  } else {
    return client.getRemoteAddress();
  }
}

代码示例来源:origin: net.jahhan/dubbo-rpc-default

public InetSocketAddress getRemoteAddress() {
  if (client == null) {
    return InetSocketAddress.createUnresolved(url.getHost(), url.getPort());
  } else {
    return client.getRemoteAddress();
  }
}

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

public InetSocketAddress getRemoteAddress() {
  if (client == null){
    return InetSocketAddress.createUnresolved(url.getHost(), url.getPort());
  } else {
    return client.getRemoteAddress();
  }
}
public ResponseFuture request(Object request, int timeout) throws RemotingException {

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

public InetSocketAddress getRemoteAddress() {
  if (client == null){
    return InetSocketAddress.createUnresolved(url.getHost(), url.getPort());
  } else {
    return client.getRemoteAddress();
  }
}
public ResponseFuture request(Object request, int timeout) throws RemotingException {

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

public InetSocketAddress getRemoteAddress() {
  if (client == null){
    return InetSocketAddress.createUnresolved(url.getHost(), url.getPort());
  } else {
    return client.getRemoteAddress();
  }
}
public ResponseFuture request(Object request, int timeout) throws RemotingException {

代码示例来源:origin: yankai913/dubbo-rpc-thrift

public InetSocketAddress getRemoteAddress() {
  if (client == null){
    return InetSocketAddress.createUnresolved(url.getHost(), url.getPort());
  } else {
    return client.getRemoteAddress();
  }
}
public ResponseFuture request(Object request, int timeout) throws RemotingException {

代码示例来源:origin: io.eventcenter/ec-remote-dubbo

public static RegistryServiceFactory buildWith(URL url, String applicationName){
  RegistryServiceFactory factory = buildWith(url, applicationName, null);
  factory.getReferenceConfig().setUrl(new StringBuilder("dubbo://").append(url.getHost()).append(":").append(url.getPort()).toString());
  return factory;
}

代码示例来源:origin: io.eventcenter/ec-remote-dubbo

public static PublisherGroupFactory buildWith(URL url, String remoteEvents){
  PublisherGroupFactory factory = buildWith(url, remoteEvents, null);
  factory.getReferenceConfig().setUrl(new StringBuilder("dubbo://").append(url.getHost()).append(":").append(url.getPort()).toString());
  return factory;
}

代码示例来源:origin: linux-china/dubbo3

public ConsulRegistry(URL url) {
  super(url);
  if (url.isAnyHost()) {
    throw new IllegalStateException("registry address == null");
  }
  consulClient = new ConsulClient(url.getHost(), url.getPort());
}

代码示例来源:origin: linux-china/dubbo3

public ConsulRegistry(URL url) {
  super(url);
  if (url.isAnyHost()) {
    throw new IllegalStateException("registry address == null");
  }
  consulClient = new ConsulClient(url.getHost(), url.getPort());
}

代码示例来源:origin: linux-china/dubbo3

/**
 * 根据motan的url生成consul的serivce id。 serviceid 包括ip+port+rpc服务的接口类名
 *
 * @param url url
 * @return consul service id
 */
public static String convertConsulSerivceId(URL url) {
  if (url == null) {
    return null;
  }
  return convertServiceId(url.getHost(), url.getPort(), url.getPath());
}

代码示例来源:origin: linux-china/dubbo3

/**
 * 根据motan的url生成consul的serivce id。 serviceid 包括ip+port+rpc服务的接口类名
 *
 * @param url url
 * @return consul service id
 */
public static String convertConsulSerivceId(URL url) {
  if (url == null) {
    return null;
  }
  return convertServiceId(url.getHost(), url.getPort(), url.getPath());
}

代码示例来源:origin: io.eventcenter/ec-remote-dubbo

protected RemoteSubscriberFactory createRemoteSubscriberFactory(URL url, String address, RegistryConfig registryConfig){
  RemoteSubscriberFactory factory = RemoteSubscriberFactory.buildWith(url, registryConfig);
  if(devMode || isCopySendUnderSameVersion()){
    if(isCopySendUnderSameVersion()){
      factory.getReferenceConfig().setUrl(buildDubboUrl(address));
    }
    else{
      factory.getReferenceConfig().setUrl(buildDubboUrl(new StringBuilder(url.getHost()).append(":").append(url.getPort()).toString()));
    }
  }
  return factory;
}

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

protected String getAddr(URL url) {
  String bindIp = url.getParameter(Constants.BIND_IP_KEY, url.getHost());
  if (url.getParameter(Constants.ANYHOST_KEY, false)) {
    bindIp = Constants.ANYHOST_VALUE;
  }
  return NetUtils.getIpByHost(bindIp) + ":" + url.getParameter(Constants.BIND_PORT_KEY, url.getPort());
}

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

protected String getAddr(URL url) {
  String bindIp = url.getParameter(Constants.BIND_IP_KEY, url.getHost());
  if (url.getParameter(Constants.ANYHOST_KEY, false)) {
    bindIp = Constants.ANYHOST_VALUE;
  }
  return NetUtils.getIpByHost(bindIp) + ":" + url.getParameter(Constants.BIND_PORT_KEY, url.getPort());
}

相关文章

微信公众号

最新文章

更多