1. дома
  2. Вопрос и ответ
  3. javax.ws.rs.WebApplicationException: HTTP 404 сервер не смог найти запрошенный ресурс

javax.ws.rs.WebApplicationException: HTTP 404 сервер не смог найти запрошенный ресурс

2015-08-21 5 views
0

Я использовал API-интерфейс Java Java Kubernetes для создания приложения, которое создает контроллеры репликации Kubernetes следующим образом.javax.ws.rs.WebApplicationException: HTTP 404 сервер не смог найти запрошенный ресурс

import io.fabric8.kubernetes.api.KubernetesClient; 
import io.fabric8.kubernetes.api.KubernetesFactory; 
import io.fabric8.kubernetes.api.model.*; 
import io.fabric8.kubernetes.api.model.resource.Quantity; 
import io.fabric8.kubernetes.client.KubernetesClientException; 
import org.apache.commons.logging.Log; 
import org.apache.commons.logging.LogFactory; 
import org.apache.stratos.kubernetes.client.interfaces.ReplicationControllerClientAPIInterface; 

import java.util.ArrayList; 
import java.util.HashMap; 
import java.util.List; 
import java.util.Map; 

public class ReplicationControllerClientAPI implements ReplicationControllerClientAPIInterface { 

    private final KubernetesClient kubernetesClient; 

    private static final Log LOG = LogFactory.getLog(ReplicationControllerClientAPI.class); 

    public ReplicationControllerClientAPI(String endpointURL) { 
     kubernetesClient = new KubernetesClient(new KubernetesFactory(endpointURL)); 
     System.out.println(endpointURL); 
    } 

    public void createReplicationController(String replicationControllerID, String selectorLabel, 
      int replicas, String containerName, String dockerImage, int cpu, int memory, 
      List<ContainerPort> ports) throws KubernetesClientException { 

     try { 
      int memoryInMB = 1024 * 1024 * memory; 
      if (LOG.isDebugEnabled()) { 
       LOG.debug(String.format("Creating kubernetes replication-controller: [rc-id] %s " 
           + "[container-name] %s [docker-image] %s " 
           + "[cpu] %d [memory] %d MB [ports] %s", 
         replicationControllerID, containerName, dockerImage, cpu, memoryInMB, ports)); 
      } 

      // Create replication-controller definition 
      ReplicationController replicationController = new ReplicationController(); 

      replicationController.setApiVersion(ReplicationController.ApiVersion.V_1); 
      replicationController.setKind(KubernetesConstantsExtended.KIND_REPLICATION_CONTROLLER); 

      ObjectMeta replicationControllerMetaData = new ObjectMeta(); 
      replicationControllerMetaData.setName(replicationControllerID); 
      replicationController.setMetadata(replicationControllerMetaData); 

      ReplicationControllerSpec replicationControllerSpec = new ReplicationControllerSpec(); 
      replicationControllerSpec.setReplicas(replicas); 

      // Setup label selectors for the replication controller 
      Map<String, String> selectors = new HashMap<String, String>(); 
      selectors.put(KubernetesConstantsExtended.LABEL_NAME_REPLICATION_CONTROLLER, selectorLabel); 
      replicationControllerSpec.setSelector(selectors); 

      PodTemplateSpec podTemplateSpec = new PodTemplateSpec(); 

      ObjectMeta podMetaData = new ObjectMeta(); 
      podMetaData.setLabels(selectors); 
      podTemplateSpec.setMetadata(podMetaData); 

      PodSpec podSpec = new PodSpec(); 

      List<Container> containers = new ArrayList<Container>(); 
      // Create container definition 
      Container container = new Container(); 
      container.setName(containerName); 
      container.setImage(dockerImage); 
      // Set resource limits 
      ResourceRequirements resources = new ResourceRequirements(); 
      Map<String, Quantity> limits = new HashMap<String, Quantity>(); 
      limits.put(KubernetesConstants.RESOURCE_CPU, new Quantity(String.valueOf(cpu))); 
      limits.put(KubernetesConstants.RESOURCE_MEMORY, new Quantity(String.valueOf(memoryInMB))); 
      resources.setLimits(limits); 
      container.setResources(resources); 
      // Add container definition to the list of containers 
      containers.add(container); 

      podSpec.setContainers(containers); 

      // Add Pod Spec to the Pod Template Spec 
      podTemplateSpec.setSpec(podSpec); 
      // Add Pod Template Spec to the ReplicationController Spec 
      replicationControllerSpec.setTemplate(podTemplateSpec); 
      // Add Replication Controller Spec to the Replication Controller instance 
      replicationController.setSpec(replicationControllerSpec); 

      // Create the replication-controller 
      kubernetesClient.createReplicationController(replicationController); 
     } catch (Exception e) { 
      String message = String.format("Could not create kubernetes replication-controller: " 
        + "[rc-id] %s", replicationControllerID); 
      LOG.error(message, e); 
      throw new KubernetesClientException(message, e); 
     } 
    } 

    public ReplicationController getReplicationController(String replicationControllerID) 
      throws KubernetesClientException { 
     try { 
      return kubernetesClient.getReplicationController(replicationControllerID); 
     } catch (Exception e) { 
      String message = String.format("Could not retrieve kubernetes replication-controller" 
        + ": [rc-id] %s", replicationControllerID); 
      LOG.error(message, e); 
      throw new KubernetesClientException(message, e); 
     } 
    } 

    public ReplicationControllerList getReplicationControllers() 
      throws KubernetesClientException { 
     try { 
      return kubernetesClient.getReplicationControllers(); 
     } catch (Exception e) { 
      String message = String.format("Could not retrieve kubernetes replication-controllers"); 
      LOG.error(message, e); 
      throw new KubernetesClientException(message, e); 
     } 
    } 

    public void deleteReplicationController(String replicationControllerID) 
      throws KubernetesClientException { 
     try { 
      kubernetesClient.deleteReplicationController(replicationControllerID); 
     } catch (Exception e) { 
      String message = String.format("Could not delete kubernetes replication-controller" 
        + ": [rc-id] %s", replicationControllerID); 
      LOG.error(message, e); 
      throw new KubernetesClientException(message, e); 
     } 
    } 
}

Когда я выполняю вышеуказанный код, я обнаружил, что приложение выбрасывает следующее исключение.

javax.ws.rs.WebApplicationException: HTTP 404 the server could not find the requested resource 
    at io.fabric8.kubernetes.api.ExceptionResponseMapper.fromResponse(ExceptionResponseMapper.java:44) 
    at io.fabric8.kubernetes.api.ExceptionResponseMapper.fromResponse(ExceptionResponseMapper.java:35) 
    at org.apache.cxf.jaxrs.client.ClientProxyImpl.checkResponse(ClientProxyImpl.java:302) 
    at org.apache.cxf.jaxrs.client.ClientProxyImpl.handleResponse(ClientProxyImpl.java:725) 
    at org.apache.cxf.jaxrs.client.ClientProxyImpl.doChainedInvocation(ClientProxyImpl.java:683) 
    at org.apache.cxf.jaxrs.client.ClientProxyImpl.invoke(ClientProxyImpl.java:224) 
    at com.sun.proxy.$Proxy18.createReplicationController(Unknown Source) 
    at io.fabric8.kubernetes.api.KubernetesClient.createReplicationController(KubernetesClient.java:460) 
    at io.fabric8.kubernetes.api.KubernetesClient.createReplicationController(KubernetesClient.java:450) 
    at org.apache.stratos.kubernetes.client.ReplicationControllerClientAPI.createReplicationController(ReplicationControllerClientAPI.java:108) 
    at org.apache.stratos.kubernetes.client.ReplicationControllerTestSuite.createReplicationController(ReplicationControllerTestSuite.java:44) 
    at org.apache.stratos.kubernetes.client.ReplicationControllerTestExecutor.main(ReplicationControllerTestExecutor.java:22) 
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) 
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
    at java.lang.reflect.Method.invoke(Method.java:606) 
    at com.intellij.rt.execution.application.AppMain.main(AppMain.java:140) 

Exception in thread "main" io.fabric8.kubernetes.client.KubernetesClientException: Could not create kubernetes replication-controller: [rc-id] helloworldrc 
    at org.apache.stratos.kubernetes.client.ReplicationControllerClientAPI.createReplicationController(ReplicationControllerClientAPI.java:113) 
    at org.apache.stratos.kubernetes.client.ReplicationControllerTestSuite.createReplicationController(ReplicationControllerTestSuite.java:44) 
    at org.apache.stratos.kubernetes.client.ReplicationControllerTestExecutor.main(ReplicationControllerTestExecutor.java:22) 
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) 
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
    at java.lang.reflect.Method.invoke(Method.java:606) 
    at com.intellij.rt.execution.application.AppMain.main(AppMain.java:140) 
Caused by: javax.ws.rs.WebApplicationException: HTTP 404 the server could not find the requested resource 
    at io.fabric8.kubernetes.api.ExceptionResponseMapper.fromResponse(ExceptionResponseMapper.java:44) 
    at io.fabric8.kubernetes.api.ExceptionResponseMapper.fromResponse(ExceptionResponseMapper.java:35) 
    at org.apache.cxf.jaxrs.client.ClientProxyImpl.checkResponse(ClientProxyImpl.java:302) 
    at org.apache.cxf.jaxrs.client.ClientProxyImpl.handleResponse(ClientProxyImpl.java:725) 
    at org.apache.cxf.jaxrs.client.ClientProxyImpl.doChainedInvocation(ClientProxyImpl.java:683) 
    at org.apache.cxf.jaxrs.client.ClientProxyImpl.invoke(ClientProxyImpl.java:224) 
    at com.sun.proxy.$Proxy18.createReplicationController(Unknown Source) 
    at io.fabric8.kubernetes.api.KubernetesClient.createReplicationController(KubernetesClient.java:460) 
    at io.fabric8.kubernetes.api.KubernetesClient.createReplicationController(KubernetesClient.java:450) 
    at org.apache.stratos.kubernetes.client.ReplicationControllerClientAPI.createReplicationController(ReplicationControllerClientAPI.java:108) 
    ... 7 more 

Process finished with exit code 1

Я установки конечной точки URL в KubernetesClient к http://127.0.0.1:8080, как я бегу Kubernetes локально через Docker для целей тестирования. Я следил за несколькими предыдущими сообщениями, связанными с подобными проблемами, но ни один из них, похоже, не помогает мне в этом случае.

Я установил следующие переменные окружающей среды в моем .bashrc.

export KUBERNETES_SERVICE_HOST=127.0.0.1 
export KUBERNETES_SERVICE_PORT=8080

Следующие образцы кода используются для настройки KubernetesClient в моем приложении.

private final ReplicationControllerClientAPIInterface REPLICATION_CONTROLLER_CLIENT; 

    public ReplicationControllerTestSuite() { 
     REPLICATION_CONTROLLER_CLIENT = new ReplicationControllerClientAPI("http://" 
       + ReplicationControllerTestConstants.KUBERNETES_SERVICE_HOST + ":" 
       + ReplicationControllerTestConstants.KUBERNETES_SERVICE_PORT); 

//  REPLICATION_CONTROLLER_CLIENT = new ReplicationControllerClientAPI("http://localhost:8080"); 
    } 

    public void createReplicationController(int replicas) { 
     List<ContainerPort> exposedPorts = new ArrayList<ContainerPort>(); 
     ContainerPort port = new ContainerPort(); 
     port.setContainerPort(ReplicationControllerTestConstants.EXPOSED_PORT); 
     exposedPorts.add(port); 

     REPLICATION_CONTROLLER_CLIENT.createReplicationController(
       ReplicationControllerTestConstants.REPLICATION_CONTROLLER_ID, ReplicationControllerTestConstants.SELECTOR_LABEL, 
       replicas, ReplicationControllerTestConstants.CONTAINER_NAME, ReplicationControllerTestConstants.DEFAULT_DOCKER_IMAGE, 
       ReplicationControllerTestConstants.CPU_CORES, ReplicationControllerTestConstants.MEMORY_ALLOCATION, exposedPorts); 
    }

Константы в приведенном выше коде, обратитесь к следующему:

protected static final String KUBERNETES_SERVICE_HOST = "127.0.0.1"; 
    protected static final String KUBERNETES_SERVICE_PORT = "8080"; 
    protected static final String SELECTOR_LABEL = "helloworld"; 
    protected static final String REPLICATION_CONTROLLER_ID = "helloworldrc"; 
    // Container specific 
    protected static final String DEFAULT_DOCKER_IMAGE = "helloworld"; 
    protected static final String CONTAINER_NAME = "helloworld"; 
    protected static final int CPU_CORES = 1; 
    protected static final int MEMORY_ALLOCATION = 512; 
    protected static final int EXPOSED_PORT = 8080;

Любая помощь в отношении этого вопроса высоко ценится, как мне известно, на REST API и Kubernetes ограничен.

источник

2015-08-21 Chiranga Alwis

ответ

0

Мне удалось исправить вышеупомянутую проблему, избегая использования https://github.com/apache/stratos, который является одной зависимостью, которую я использую в своем коде. Я намеревался использовать свои уже созданные возможности, такие как KubernetesClientException в моем коде, но вышеупомянутая проблема, похоже, появляется из-за этой зависимости.

Но я не совсем уверен в причине конкретной проблемы.

источник

2015-08-22 18:51:02

0

Существует переписанная версия клиента fabric8 kubernetes с меньшим количеством зависимостей, плавная DSL & улучшенная поддержка часов. Это в отдельном репо на https://github.com/fabric8io/kubernetes-client & артефактов, доступных в Maven центральных помощью следующей зависимости:

<dependency> 
    <groupId>io.fabric8</groupId> 
    <artifactId>kubernetes-client</artifactId> 
    <version>1.3.6</version> 
</dependency>

Обратите внимание, что существует частые выпуски с обновлениями, но в настоящее время API стабильно & готова к продуктивному использованию.

An example создать контроллер репликации выглядит следующим образом:

Config config = new ConfigBuilder().withMasterUrl(master).build(); 

try (final KubernetesClient client = new DefaultKubernetesClient(config)) { 

    client.replicationControllers().inNamespace("thisisatest").createNew() 
     .withNewMetadata().withName("nginx2-controller").addToLabels("server", "nginx").endMetadata() 
     .withNewSpec().withReplicas(0) 
     .withNewTemplate() 
     .withNewMetadata().addToLabels("server", "nginx2").endMetadata() 
     .withNewSpec() 
     .addNewContainer().withName("nginx").withImage("nginx") 
     .addNewPort().withContainerPort(80).endPort() 
     .endContainer() 
     .endSpec() 
     .endTemplate() 
     .endSpec().done(); 

} catch (Exception e) { 
    e.printStackTrace(); 
    logger.error(e.getMessage(), e); 
}

Клиент легко настраивается с помощью конфигурации строителя & охватывает все основные типы Kubernetes, а также OpenShift 3 расширения.

Обновление: После вашего собственного ответа, я поднял JIRA с проектом Stratos, чтобы перейти на новый клиент - в настоящее время они делают какое-то переупаковка старого клиента & это, вероятно, вызывает ваши проблемы. См. Issues.apache.org/jira/browse/STRATOS-1524

источник

2015-08-21 19:33:12

 Смежные вопросы

  • Нет связанных вопросов^_^