我正在嘗試將數據從 HTTP (GET) 響應流式傳輸到另一個 HTTP (POST) 請求。使用舊的 HttpURLConnection，我將獲取響應 OutputStream，將部分讀入緩沖區并將它們寫入請求 InputStream。通過創建我自己的 Publisher，我已經設法在 Java 11 中對 HttpClient 執行相同的操作，該 Publisher 在 POST 中用于編寫請求正文。GET 請求有一個BodyHandlerwithofByteArrayConsumer將塊發送到自定義發布者，然后它自己將塊發送到訂閱 HTTP POST 請求。但我認為這不是正確的方法，因為看起來 API 中有一些東西看起來可以直接完成而無需自己實現發布者和訂閱者。有HttpResponse.BodyHandlers.ofPublisher()一個返回一個Publisher<List<ByteBuffer>我可以用于 HTTP GET 請求的。不幸的是，對于我的 POST 請求，有HttpRequest.BodyPublishers.fromPublisher一個期望值Publisher<? extends ByteBuffer>，因此 fromPublisher 似乎只適用于擁有完整 ByteBuffer 的發布者，而不適用于為部分數據發送多個 ByteBuffer 的發布者。我是否錯過了一些能夠將 BodyPublisher 從一個請求連接到另一個請求的東西？
1 回答
墨色風雨
TA貢獻1853條經驗 獲得超6個贊
你沒有遺漏任何東西。這只是一個目前不支持開箱即用的用例。ByteBuffer盡管從到的映射List<ByteBuffer>很簡單，但逆映射卻不那么簡單。從一個適應另一個的一種簡單（如果不是最佳）方法可能是將列表中的所有緩沖區收集到一個緩沖區中 - 如果您想控制從上游接收的每個已發布的字節數，則可能結合HttpResponse.BodyHandlers.ofPublisher()使用.HttpResponse.BodyHandlers.buffering()List<ByteBuffer>
添加回答
舉報
0/150
提交
取消