本文整理了Java中com.alibaba.dubbo.common.URL.getHost()
方法的一些代码示例,展示了URL.getHost()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。URL.getHost()
方法的具体详情如下:
包路径:com.alibaba.dubbo.common.URL
类名称: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());
}
内容来源于网络,如有侵权,请联系作者删除!