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

URL.getParameter介绍

暂无

代码示例

代码示例来源：origin: apache/incubator-dubbo

@Override
public String getParameterAndDecoded(String key, String defaultValue) {
  return org.apache.dubbo.common.URL.decode(getParameter(key, defaultValue));
}

代码示例来源：origin: apache/incubator-dubbo

@Override
public String getParameterAndDecoded(String key, String defaultValue) {
  return org.apache.dubbo.common.URL.decode(getParameter(key, defaultValue));
}

代码示例来源：origin: alibaba/dubbo-spring-boot-starter

@Override
public void referred(Invoker<?> invoker) throws RpcException {
 Class<?> interfaceClass = invoker.getInterface();
 URL url = invoker.getUrl();
 String group = url.getParameter(DubboSpringBootStarterConstants.GROUP);
 String version = url.getParameter(DubboSpringBootStarterConstants.VERSION);
 ClassIdBean classIdBean = new ClassIdBean(interfaceClass, group, version);
 SUBSCRIBEDINTERFACES_SET.add(classIdBean);
}

代码示例来源：origin: alibaba/dubbo-spring-boot-starter

@Override
 public void destroyed(Invoker<?> invoker) {
  Class<?> interfaceClass = invoker.getInterface();
  URL url = invoker.getUrl();
  String group = url.getParameter(DubboSpringBootStarterConstants.GROUP);
  String version = url.getParameter(DubboSpringBootStarterConstants.VERSION);
  ClassIdBean classIdBean = new ClassIdBean(interfaceClass, group, version);
  SUBSCRIBEDINTERFACES_SET.remove(classIdBean);
 }
}

代码示例来源：origin: shuzheng/zheng

@Around("execution(* *..rpc..*.*(..))")
public Object doAround(ProceedingJoinPoint pjp) throws Throwable {
  Object result = pjp.proceed();
  // 是否是消费端
  boolean consumerSide = RpcContext.getContext().isConsumerSide();
  // 获取最后一次提供方或调用方IP
  String ip = RpcContext.getContext().getRemoteHost();
  // 服务url
  String rpcUrl = RpcContext.getContext().getUrl().getParameter("application");
  LOGGER.info("consumerSide={}, ip={}, url={}", consumerSide, ip, rpcUrl);
  return result;
}

代码示例来源：origin: alibaba/Sentinel

@Override
  public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
    String application = invoker.getUrl().getParameter(Constants.APPLICATION_KEY);
    if (application != null) {
      RpcContext.getContext().setAttachment(DubboUtils.DUBBO_APPLICATION_KEY, application);
    }
    return invoker.invoke(invocation);
  }
}

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

public Statistics(URL url) {
  this.url = url;
  this.application = url.getParameter(MonitorService.APPLICATION);
  this.service = url.getParameter(MonitorService.INTERFACE);
  this.method = url.getParameter(MonitorService.METHOD);
  this.group = url.getParameter(MonitorService.GROUP);
  this.version = url.getParameter(MonitorService.VERSION);
  this.client = url.getParameter(MonitorService.CONSUMER, url.getAddress());
  this.server = url.getParameter(MonitorService.PROVIDER, url.getAddress());
}

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

public double getPositiveParameter(String key, double defaultValue) {
  if (defaultValue <= 0) {
    throw new IllegalArgumentException("defaultValue <= 0");
  }
  double value = getParameter(key, defaultValue);
  if (value <= 0) {
    return defaultValue;
  }
  return value;
}

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

public short getPositiveParameter(String key, short defaultValue) {
  if (defaultValue <= 0) {
    throw new IllegalArgumentException("defaultValue <= 0");
  }
  short value = getParameter(key, defaultValue);
  if (value <= 0) {
    return defaultValue;
  }
  return value;
}

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

/**
 * is consumer side.
 *
 * @return consumer side.
 */
public boolean isConsumerSide() {
  return getUrl().getParameter(Constants.SIDE_KEY, Constants.PROVIDER_SIDE).equals(Constants.CONSUMER_SIDE);
}

代码示例来源：origin: dubboclub/dubbo-plus

public static StringBuffer getInterfacePropertyName(Invoker<?> invoker){
  String interfaceName = invoker.getUrl().getParameter(Constants.INTERFACE_KEY);
  StringBuffer interfaceConfig = new StringBuffer(DUBBO_REFERENCE_PREFIX);
  interfaceConfig.append(interfaceName);
  return interfaceConfig;
}

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

protected static TProtocol newProtocol(URL url, ChannelBuffer buffer) throws IOException {
  String protocol = url.getParameter(ThriftConstants.THRIFT_PROTOCOL_KEY,
      ThriftConstants.DEFAULT_PROTOCOL);
  if (ThriftConstants.BINARY_THRIFT_PROTOCOL.equals(protocol)) {
    return new TBinaryProtocol(new TIOStreamTransport(new ChannelBufferOutputStream(buffer)));
  }
  throw new IOException("Unsupported protocol type " + protocol);
}

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

public ConnectionOrderedChannelHandler(ChannelHandler handler, URL url) {
  super(handler, url);
  String threadName = url.getParameter(Constants.THREAD_NAME_KEY, Constants.DEFAULT_THREAD_NAME);
  connectionExecutor = new ThreadPoolExecutor(1, 1,
      0L, TimeUnit.MILLISECONDS,
      new LinkedBlockingQueue<Runnable>(url.getPositiveParameter(Constants.CONNECT_QUEUE_CAPACITY, Integer.MAX_VALUE)),
      new NamedThreadFactory(threadName, true),
      new AbortPolicyWithReport(threadName, url)
  );  // FIXME There's no place to release connectionExecutor!
  queuewarninglimit = url.getParameter(Constants.CONNECT_QUEUE_WARNING_SIZE, Constants.DEFAULT_CONNECT_QUEUE_WARNING_SIZE);
}

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

/**
   * append thread name with url address
   *
   * @return new url with updated thread name
   */
  public static URL setThreadName(URL url, String defaultName) {
    String name = url.getParameter(Constants.THREAD_NAME_KEY, defaultName);
    name = name + "-" + url.getAddress();
    url = url.addParameter(Constants.THREAD_NAME_KEY, name);
    return url;
  }
}

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

private static boolean isInstancesOverLimit(Channel channel, URL url, String interfaceClass, int instid, boolean isServer) {
  Integer count = (Integer) channel.getAttribute(isServer ? getServerSideCountKey(channel, interfaceClass) : getClientSideCountKey(interfaceClass));
  int limit = url.getParameter(Constants.CALLBACK_INSTANCES_LIMIT_KEY, Constants.DEFAULT_CALLBACK_INSTANCES);
  if (count != null && count >= limit) {
    //client side error
    throw new IllegalStateException("interface " + interfaceClass + " `s callback instances num exceed providers limit :" + limit
        + " ,current num: " + (count + 1) + ". The new callback service will not work !!! you can cancle the callback service which exported before. channel :" + channel);
  } else {
    return false;
  }
}

代码示例来源：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: com.alibaba/dubbo

@Override
public void referred(Invoker<?> invoker) throws RpcException {
  if (invoker.getUrl().getParameter(Constants.DEPRECATED_KEY, false)) {
    LOGGER.error("The service " + invoker.getInterface().getName() + " is DEPRECATED! Declare from " + invoker.getUrl());
  }
}

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

@Override
protected void doRegister(URL url) {
  try {
    zkClient.create(toUrlPath(url), url.getParameter(Constants.DYNAMIC_KEY, true));
  } catch (Throwable e) {
    throw new RpcException("Failed to register " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);
  }
}

代码示例来源：origin: apache/incubator-dubbo-samples

public static void main(String[] args) {
    ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"spring/dubbo-context-consumer.xml"});
    context.start();
    ContextService contextService = (ContextService) context.getBean("demoService"); // get remote service proxy

    String hello = contextService.sayHello("world"); // call remote method

    boolean isConsumerSide = RpcContext.getContext().isConsumerSide();
    String application = RpcContext.getContext().getUrl().getParameter("application");
    String serverIP = RpcContext.getContext().getRemoteHost();

    System.out.println(hello); // get result

  }
}

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

protected static Codec2 getChannelCodec(URL url) {
  String codecName = url.getParameter(Constants.CODEC_KEY, "telnet");
  if (ExtensionLoader.getExtensionLoader(Codec2.class).hasExtension(codecName)) {
    return ExtensionLoader.getExtensionLoader(Codec2.class).getExtension(codecName);
  } else {
    return new CodecAdapter(ExtensionLoader.getExtensionLoader(Codec.class)
        .getExtension(codecName));
  }
}