404 при использовании весеннего облака FeignClients
Это моя установка:
Первый сервис (FlightIntegrationApplication), который вызывает второй сервис (BaggageServiceApplication) с использованием API-интерфейса FeignClients и Eureka.
Проект на github: https://github.com/IdanFridman/BootNetflixExample
Первый сервис:
@SpringBootApplication
@EnableCircuitBreaker
@EnableDiscoveryClient
@ComponentScan("com.bootnetflix")
public class FlightIntegrationApplication {
public static void main(String[] args) {
new SpringApplicationBuilder(FlightIntegrationApplication.class).run(args);
}
}
в одном из контроллеров:
@RequestMapping("/flights/baggage/list/{id}")
public String getBaggageListByFlightId(@PathVariable("id") String id) {
return flightIntegrationService.getBaggageListById(id);
}
FlightIntegrationService:
public String getBaggageListById(String id) {
URI uri = registryService.getServiceUrl("baggage-service", "http://localhost:8081/baggage-service");
String url = uri.toString() + "/baggage/list/" + id;
LOG.info("GetBaggageList from URL: {}", url);
ResponseEntity<String> resultStr = restTemplate.getForEntity(url, String.class);
LOG.info("GetProduct http-status: {}", resultStr.getStatusCode());
LOG.info("GetProduct body: {}", resultStr.getBody());
return resultStr.getBody();
}
RegistryService:
@Named
public class RegistryService {
private static final Logger LOG = LoggerFactory.getLogger(RegistryService.class);
@Autowired
LoadBalancerClient loadBalancer;
public URI getServiceUrl(String serviceId, String fallbackUri) {
URI uri;
try {
ServiceInstance instance = loadBalancer.choose(serviceId);
uri = instance.getUri();
LOG.debug("Resolved serviceId '{}' to URL '{}'.", serviceId, uri);
} catch (RuntimeException e) {
// Eureka not available, use fallback
uri = URI.create(fallbackUri);
LOG.error("Failed to resolve serviceId '{}'. Fallback to URL '{}'.", serviceId, uri);
}
return uri;
}
}
И это вторая услуга (багаж-сервис):
BaggageServiceApplication:
@Configuration
@ComponentScan("com.bootnetflix")
@EnableAutoConfiguration
@EnableEurekaClient
@EnableFeignClients
public class BaggageServiceApplication {
public static void main(String[] args) {
new SpringApplicationBuilder(BaggageServiceApplication.class).run(args);
}
}
BaggageService:
@FeignClient("baggage-service")
public interface BaggageService {
@RequestMapping(method = RequestMethod.GET, value = "/baggage/list/{flight_id}")
List<String> getBaggageListByFlightId(@PathVariable("flight_id") String flightId);
}
BaggageServiceImpl:
@Named
public class BaggageServiceImpl implements BaggageService{
....
@Override
public List<String> getBaggageListByFlightId(String flightId) {
return Arrays.asList("2,3,4");
}
}
При вызове контроллера покоя службы интеграции рейсов я получаю:
2015-07-22 17:25:40.682 INFO 11308 --- [ XNIO-2 task-3] c.b.f.service.FlightIntegrationService : GetBaggageList from URL: http://X230-Ext_IdanF:62007/baggage/list/4
2015-07-22 17:25:43.953 ERROR 11308 --- [ XNIO-2 task-3] io.undertow.request : UT005023: Exception handling request to /flights/baggage/list/4
org.springframework.web.util.NestedServletException: Request processing failed; nested exception is org.springframework.web.client.HttpClientErrorException: 404 Not Found
at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:978)
Любая идея?
Спасибо, Рэй.
2 ответа
Ваш код смотрит назад на меня.
Симулированный клиент для службы багажа должен быть объявлен в службе полета, а служба багажа должна иметь контроллер, который отвечает на URL, который вы отображаете в своем клиенте службы багажа, вы не должны реализовывать интерфейс, помеченный как @FeignClient
,
У вашей установки сейчас не будет никакого контроллера, прослушивающего /baggage/list/{flightId} в службе багажа, и не будет клиента Feign в службе полета - весь смысл Feign в том, чтобы вызывать методы на интерфейсе вместо ручной обработки URL-адресов, Spring Cloud позаботится об автоинстанцировании реализации интерфейса и будет использовать Eureka для обнаружения.
Попробуйте это (или измените так, чтобы оно соответствовало вашему реальному приложению):
Полетное обслуживание:
FlightIntegrationService.java:
@Component
public class FlightIntegrationService {
@Autowired
BaggageService baggageService;
public String getBaggageListById(String id) {
return baggageService.getBaggageListByFlightId(id);
}
}
BaggageService.java:
@FeignClient("baggage-service")
public interface BaggageService {
@RequestMapping(method = RequestMethod.GET, value = "/baggage/list/{flight_id}")
List<String> getBaggageListByFlightId(@PathVariable("flight_id") String flightId);
}
Багажная служба:
BaggageController.java:
@RestController
public class BaggageController {
@RequestMapping("/baggage/list/{flightId}")
public List<String> getBaggageListByFlightId(@PathVariable String flightId) {
return Arrays.asList("2,3,4");
}
}
Удалите BaggageService.java и BaggageServiceImpl.java из Службы багажа
registryService.getServiceUrl("baggage-service", ...
заменить
registryService.getServiceUrl("baggage-service")
убедитесь, что это соответствует правильному имени
удалить часть localhost
или используйте только http: // локальную часть
Это сработало только для нас, если у вас есть только название службы, указанное в панели инструментов eureka, а не оба