Я пытаюсь реализовать небольшое приложение REST на основе JAX-RS. Он имеет внутренний сервер и небольшой клиент. Клиент в основном читает из таблицы и отправляет данные таблицы в виде значений POST на сервер REST. Это метод ресурса, который обрабатывает POST-запрос.
@POST
@Consumes({MediaType.APPLICATION_JSON})
@Produces({MediaType.APPLICATION_JSON})
public Response migrateToMinio(Attachment attachment, @Context UriInfo uriInfo) throws Exception {
Integer id = attachmentService.createNew(attachment);
UriBuilder builder = uriInfo.getAbsolutePathBuilder();
builder.path(Integer.toString(id));
return Response.created(builder.build()).build();
}
Это код клиента:
public static void main(String[] args) throws Exception {
// Fire first (full?) update trigger here
fireInitialMigration();
// For subsequent (incremental?) updates, schedule an HTTP POST to occur at a fixed rate:
EXECUTOR.scheduleAtFixedRate(() -> fireSubsequentUpdate(), INITIAL_DELAY, UPDATE_RATE, TimeUnit.MILLISECONDS);
// Keep main thread alive
while (true) ;
}
private static void fireInitialMigration() throws Exception {
TiedostoService tiedostoService = new TiedostoService();
List<Tiedosto> tiedostoList = tiedostoService.getAllFiles();
Client client = ClientBuilder.newClient();
List<Response> responseList = new ArrayList<>();
for (Tiedosto tiedosto : tiedostoList){
Attachment attachment = new Attachment();
attachment.setCustomerId(tiedosto.getCustomerId());
attachment.setSize(tiedosto.getFileSize());
System.out.println(attachment.getCustomerId()+" "+attachment.getSize());
Response res = client.target("http://localhost:8080/myapp/attachments")
.request("application/json")
.post(Entity.entity(attachment, MediaType.APPLICATION_JSON), Response.class);
responseList.add(res);
}
System.out.println(responseList);
}
private static void fireSubsequentUpdate() {
// Similar to initialMigration(), but change Entity/set of HTTP POSTs according to your needs.
}
fireInitialMigration () должен прочитать таблицу и сохранить значение в List <>. Затем список повторяется внутри цикла for, значения извлекаются и присваиваются экземплярам класса Attachment и, наконец, отправляются как POST. Теперь, когда я запускаю клиент, он работает до System.out.println(attachment.getCustomerId()+" "+attachment.getSize());
Выход
После этого клиент выдает ошибку HTTP 500 request, как это
InboundJaxrsResponse{context=ClientResponse{method=POST, uri=http://localhost:8080/myapp/attachments, status=500, reason=Request failed.}}, InboundJaxrsResponse{context=ClientResponse{method=POST, uri=http://localhost:8080/myapp/attachments, status=500, reason=Request failed.}}, InboundJaxrsResponse{context=ClientResponse{method=POST, uri=http://localhost:8080/myapp/attachments, status=500, reason=Request failed.}}
Когда я пытаюсь вручную ввести данные с помощью основного метода в серверной части, как это, он работает нормально.
public static void main(String[] args) {
AttachmentService attachmentService = new AttachmentService();
Integer id = null;
Attachment attachment = new Attachment();
attachment.setCustomerId(150);
attachment.setSize(8096);
try{
id = attachmentService.createNew(attachment);
} catch (Exception e) {
e.printStackTrace();
}
}
Я застрял с этим некоторое время, я очень признателен за любую помощь / руководство.