我正在嘗試使用com.gluonhq.connect.provider.RestClient來查詢啟用了 Elastic Search 的 API。
Maven:
<dependency>
<groupId>com.gluonhq</groupId>
<artifactId>connect</artifactId>
<version>2.0.1</version>
</dependency>
我嘗試使用以下方法發出請求：
private GluonObservableObject<Item> getData() {
RestClient myApiClient = RestClient.create()
.method("POST")
.host(applicationProperties.getAPIURL())
.path("search")
.header("accept", "application/json")
.header("Content-type", "application/json")
.queryParam("private_key", applicationProperties.getAPIKEY())
.dataString(ITEMREQUEST);
return DataProvider.retrieveObject(
myApiClient.createObjectDataReader(Item.class));
}
...其中 dataString 是一個 json 格式的字串，表示請求的主體（我可以假設請求的格式正確，因為我在 Postman 中對其進行了測驗并且請求回傳了預期的資料）。如果有幫助，這里是彈性搜索請求正文：
{
"indexes": "idx1, idx2",
"columns": "col1,col2,col3,col4,col5",
"body": {
"query": {
"bool": {
"must": [
{
"wildcard": {
"NameCombined_en": "*"
}
}
],
"filter": [
{
"range": {
"ID": {
"gte": "20000"
}
}
}
]
}
},
"from": 0,
"size": 100
}
}
我遇到的問題是（膠子） RestClient 以及擴展的 DataProvider.retrieveObject 方法完全回傳......什么都沒有。
我很確定我做錯了什么，我很確定它是 .dataString() 方法（它需要一個“物體”），但我還沒有找到一種替代方法來用作傳遞身體的一種方式進入請求。
使用com.gluonhq.connect庫背后的原因是為了避免也必須創建我自己的 Observable 串列（手動）——如果資料格式合適......并且存在，該庫會自動吐出一個。至少，這是我對它的理解。
有人可以指出我正確的方向嗎？我沒有發現有關如何使用該庫執行 POST 請求的指示或解釋。
更新 20220117
主.java
public class Main extends Application {
ApplicationProperties applicationProperties = new ApplicationProperties();
private static final String RESTLIST_VIEW = HOME_VIEW;
private static final String RESTOBJECT_VIEW = "RestObjectView";
private final AppManager appManager = AppManager.initialize(this::postInit);
@Override
public void init() {
appManager.addViewFactory(RESTOBJECT_VIEW, () -> new RestObjectView(applicationProperties.APIURL, applicationProperties.APIKEY));
updateDrawer();
}
@Override
public void start(Stage stage) {
appManager.start(stage);
}
private void postInit(Scene scene) {
Swatch.BLUE.assignTo(scene);
((Stage) scene.getWindow()).getIcons().add(new Image(Objects.requireNonNull(Main.class.getResourceAsStream("/icon.png"))));
}
private void updateDrawer() {
NavigationDrawer navigationDrawer = appManager.getDrawer();
NavigationDrawer.Header header = new NavigationDrawer.Header("Gluon Mobile", "Gluon Connect Rest Provider Sample",
new Avatar(21, new Image(getClass().getResourceAsStream("/icon.png"))));
navigationDrawer.setHeader(header);
NavigationDrawer.Item listItem = new NavigationDrawer.Item("List Viewer", MaterialDesignIcon.VIEW_LIST.graphic());
NavigationDrawer.Item objectItem = new NavigationDrawer.Item("Object Viewer", MaterialDesignIcon.INSERT_DRIVE_FILE.graphic());
navigationDrawer.getItems().addAll(listItem, objectItem);
navigationDrawer.selectedItemProperty().addListener((obs, oldItem, newItem) -> {
if (newItem.equals(listItem)) {
appManager.switchView(RESTLIST_VIEW);
} else if (newItem.equals(objectItem)) {
appManager.switchView(RESTOBJECT_VIEW);
}
});
}
public static void main(String[] args) {
System.setProperty("javafx.platform", "Desktop");
launch(args);
}
RestObjectView.java
public class RestObjectView extends View {
public RestObjectView(String apiurl, String apikey) {
Label lbItemId = new Label();
Label lbName = new Label();
Label lbDescription = new Label();
Label lbLvlItem = new Label();
Label lbLvlEquip = new Label();
GridPane gridPane = new GridPane();
gridPane.setVgap(5.0);
gridPane.setHgap(5.0);
gridPane.setPadding(new Insets(5.0));
gridPane.addRow(0, new Label("Item ID:"), lbItemId);
gridPane.addRow(1, new Label("Name:"), lbName);
gridPane.addRow(2, new Label("Description:"), lbDescription);
gridPane.addRow(3, new Label("Item Level:"), lbLvlItem);
gridPane.addRow(4, new Label("Equip Level:"), lbLvlEquip);
gridPane.getColumnConstraints().add(new ColumnConstraints(75));
lbItemId.setWrapText(true);
lbName.setWrapText(true);
lbDescription.setWrapText(true);
lbLvlItem.setWrapText(false);
lbLvlEquip.setWrapText(false);
setCenter(gridPane);
// create a RestClient to the specific URL
RestClient restClient = RestClient.create()
.method("POST")
.host(apiurl)
.path("Item")
.queryParam("private_key", apikey);
// create a custom Converter that is able to parse the response into a single object
InputStreamInputConverter<Item> converter = new SingleItemInputConverter<>(Item.class);
// retrieve an object from the DataProvider
GluonObservableObject<Item> item = DataProvider.retrieveObject(restClient.createObjectDataReader(converter));
// when the object is initialized, bind its properties to the JavaFX UI controls
item.initializedProperty().addListener((obs, oldValue, newValue) -> {
if (newValue) {
lbItemId.textProperty().bind(item.get().itemIdProperty().asString());
lbName.textProperty().bind(item.get().nameProperty());
lbDescription.textProperty().bind(item.get().descriptionProperty());
lbLvlItem.textProperty().bind(item.get().levelItemProperty().asString());
lbLvlEquip.textProperty().bind(item.get().levelEquipProperty().asString());
}
});
}
@Override
protected void updateAppBar(AppBar appBar) {
appBar.setNavIcon(MaterialDesignIcon.MENU.button(e -> getAppManager().getDrawer().open()));
appBar.setTitleText("Rest Object Viewer");
}
}
uj5u.com熱心網友回復：
這是RestClientwithGET和的快速演示POST：
ToDoItem 班級：
public class ToDoItem {
private int userId;
private int id;
private String title;
private boolean completed;
public int getUserId() {
return userId;
}
public void setUserId(int userId) {
this.userId = userId;
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getTitle() {
return title;
}
public void setTitle(String title) {
this.title = title;
}
public boolean isCompleted() {
return completed;
}
public void setCompleted(boolean completed) {
this.completed = completed;
}
@Override
public String toString() {
return "ToDoItem{"
"userId=" userId
", id=" id
", title='" title '\''
", completed=" completed
'}';
}
}
GET 測驗：
public void getTest() {
RestClient restClient = RestClient.create()
.method("GET")
.host("http://jsonplaceholder.typicode.com")
.path("/todos/1");
GluonObservableObject<ToDoItem> singleToDoItem =
DataProvider.retrieveObject(
restClient.createObjectDataReader(ToDoItem.class));
singleToDoItem.setOnSucceeded(e ->
System.out.println("ToDoItem successfully retrieved: " singleToDoItem.get()));
singleToDoItem.setOnFailed(e -> {
System.out.println("ToDoItem GET error");
if (singleToDoItem.getException() != null) {
singleToDoItem.getException().printStackTrace();
}
});
}
POST 測驗：
public void postTest() {
ToDoItem toDoItem = new ToDoItem();
toDoItem.setCompleted(Math.random() > 0.5);
toDoItem.setTitle(UUID.randomUUID().toString());
toDoItem.setUserId(1);
// write a new todo item to a rest source
RestClient restClient = RestClient.create()
.method("POST")
.contentType("application/json")
.host("http://jsonplaceholder.typicode.com")
.path("/todos");
GluonObservableObject<ToDoItem> obsToDoItem =
DataProvider.storeObject(toDoItem,
restClient.createObjectDataWriter(ToDoItem.class));
obsToDoItem.setOnSucceeded(e ->
System.out.println("ToDoItem successfully written: " obsToDoItem.get()));
obsToDoItem.setOnFailed(e -> {
System.out.println("ToDoItem POST error");
if (obsToDoItem.getException() != null) {
obsToDoItem.getException().printStackTrace();
}
});
}
運行兩者應該會給你這樣的東西：
ToDoItem successfully retrieved: ToDoItem{userId=1, id=1, title='delectus aut autem', completed=false}
ToDoItem successfully written: ToDoItem{userId=1, id=201, title='6977035b-7a0c-4e6a-82e5-141b414db92a', completed=false}
轉載請註明出處，本文鏈接：https://www.uj5u.com/yidong/418479.html
標籤：