建站
咨詢
售后
建站咨詢
新聞中心
審校 | 孫淑娟
成都創(chuàng)新互聯(lián)公司-專業(yè)網(wǎng)站定制、快速模板網(wǎng)站建設(shè)、高性價(jià)比祁縣網(wǎng)站開(kāi)發(fā)、企業(yè)建站全套包干低至880元,成熟完善的模板庫(kù),直接使用。一站式祁縣網(wǎng)站制作公司更省心,省錢(qián),快速模板網(wǎng)站建設(shè)找我們，業(yè)務(wù)覆蓋祁縣地區(qū)。費(fèi)用合理售后完善，十多年實(shí)體公司更值得信賴。
在超快系列的第二部分中，你將學(xué)習(xí)一個(gè)新的數(shù)據(jù)庫(kù)，該數(shù)據(jù)庫(kù)可以使你的微服務(wù)在Java世界中快速擴(kuò)展！
第一部分可參看：??Java 中的超快微服務(wù)： 當(dāng)Microstream遇上Open Liberty??
當(dāng)我們談?wù)搫?chuàng)建可擴(kuò)展的應(yīng)用程序時(shí)，微服務(wù)已成為一個(gè)流行語(yǔ)。但這足夠了嗎？答案是否定的，與任何軟件架構(gòu)決策一樣，它也有一個(gè)權(quán)衡和幾個(gè)挑戰(zhàn)。對(duì)于我們Java開(kāi)發(fā)人員來(lái)說(shuō)，這兩種工具的組合使我們的工作更輕松：Microstream和MicroProfile。本文將介紹如何結(jié)合Microstream和 Wildfly 來(lái)創(chuàng)建一個(gè)性能穩(wěn)定且速度極快的微服務(wù)應(yīng)用程序。
使用 Wildfly 的微服務(wù)
作為面對(duì)分布式系統(tǒng)的第一步，微服務(wù)為軟件工程師帶來(lái)了挑戰(zhàn)。在Java世界中，有幾種工具可以使我們的生活更輕松，尤其是MicroProfile。
MicroProfile 的目標(biāo)是針對(duì)微服務(wù)架構(gòu)優(yōu)化企業(yè)版Java。它基于Java EE / Jakarta EE標(biāo)準(zhǔn)以及專門(mén)用于微服務(wù)的API，例如REST Client、 Configuration、 Open API等。
Wildfly是一個(gè)功能強(qiáng)大，模塊化和輕量級(jí)的應(yīng)用程序服務(wù)器，可幫助你構(gòu)建令人驚嘆的應(yīng)用程序。
使用Microstream實(shí)現(xiàn)數(shù)據(jù)持久化速度
當(dāng)我們談?wù)撐⒎?wù)時(shí)，我們談?wù)摰氖欠植际较到y(tǒng)及其帶來(lái)的挑戰(zhàn)，這在持久性層中也是一樣的。
不幸的是，我們沒(méi)有足夠的文章來(lái)談?wù)撍?。?dāng)你對(duì)業(yè)務(wù)有很多不確定的信息時(shí)，我們應(yīng)該有一個(gè)模型，甚至是無(wú)模式數(shù)據(jù)庫(kù)。盡管如此，持久性層仍然存在很多問(wèn)題，主要是因?yàn)樗y以更改。
制作可擴(kuò)展應(yīng)用程序的秘訣之一是無(wú)狀態(tài)，但我們?cè)诔志眯詫又胸?fù)擔(dān)不起它。首先，數(shù)據(jù)庫(kù)旨在保存信息及其狀態(tài)。
使數(shù)據(jù)持久化層更高效的解決方案之一是直接與 Java 實(shí)體集成為圖表，這就是Microstream所做的。
Microstream使用純Java實(shí)現(xiàn)了超快速的內(nèi)存數(shù)據(jù)處理。它提供微秒級(jí)查詢時(shí)間、低延遲數(shù)據(jù)訪問(wèn)、巨大的數(shù)據(jù)吞吐量和工作負(fù)載。因此，它節(jié)省了大量的CPU功率，二氧化碳排放和數(shù)據(jù)中心的成本。
顯示代碼
讓我們將兩者結(jié)合起來(lái)，制作一個(gè)Ultra-Fast Microservices。我們將選擇一個(gè)簡(jiǎn)單的演示來(lái)展示兩者如何結(jié)合。在此示例中，我們將創(chuàng)建一個(gè)簡(jiǎn)單的 CRUD，其中包含產(chǎn)品、名稱和評(píng)級(jí)，并將其導(dǎo)出為 REST API。
第一步是創(chuàng)建MicroProfile骨架：它毫不費(fèi)力且流暢，主要是因?yàn)槲覀兛梢允褂每梢暬疢icroProfile啟動(dòng)器。將 Microprofile 版本 4.1 與 Java 11 和 Wildfly 一起設(shè)置，如下圖所示：
我們已有了應(yīng)用程序的骨架。下一步是添加Microstream并使兩者協(xié)同工作。幸運(yùn)的是，有一個(gè)庫(kù)可以通過(guò)CDI擴(kuò)展集成兩者。因此，借助此API，任何具有CDI和MicroProfile Config的應(yīng)用程序都可以工作。
1.
2.one.microstream
3.microstream-integrations-cdi
4.LAST_VERSION_HERE
5.
框架已設(shè)置，讓我們從代碼開(kāi)始。模型是中心部分。它是一個(gè)平滑的示例，我們將創(chuàng)建一個(gè)包含幾個(gè)字段的產(chǎn)品實(shí)體。使用Microstream的主要建議是使用不可變實(shí)體。因此，我們將創(chuàng)建一個(gè)產(chǎn)品作為不可變實(shí)體。
1.public class Product {
2. private final long id;
3. private final String name;
4. private final String description;
5. private final int rating;
6.
7. @JsonbCreator
8. public Product(
9. @JsonbProperty("id") final long id,
10. @JsonbProperty("name") final String name,
11. @JsonbProperty("description") final String description,
12. @JsonbProperty("rating") final int rating){
13. //...
14. }
15.
16.}JSON注釋只告知MicroProfile如何將實(shí)體序列化為JSON。下一步是定義產(chǎn)品集合，我們稱之為庫(kù)存。庫(kù)存類是具有多種操作方法的一組產(chǎn)品。此類是實(shí)體與Microstream引擎之間的鏈接。與Microstream 的連接將使用Storage 注解。
1.import java.util.Collections;
2.import java.util.HashSet;
3.import java.util.Objects;
4.import java.util.Optional;
5.import java.util.Set;
6.import java.util.function.Predicate;
7.
8.import one.microstream.integrations.cdi.types.Storage;
9.
10.
11.@Storage
12.public class Inventory {
13. private final Setproducts = new HashSet<>();
14.
15. public void add(final Product product) {
16. Objects.requireNonNull(product, "product is required");
17. this.products.add(product);
18. }
19.
20. public SetgetProducts() {
21. return Collections.unmodifiableSet(this.products);
22. }
23.
24. public OptionalfindById(final long id) {
25. return this.products.stream().filter(this.isIdEquals(id)).limit(1).findFirst();
26. }
27.
28. public void deleteById(final long id) {
29. this.products.removeIf(this.isIdEquals(id));
30.
31. }
32.
33. private PredicateisIdEquals(final long id) {
34. return p -> p.getId() == id;
35. }
36.
37. @Override
38. public boolean equals(Object o) {
39. if (this == o) return true;
40. if (o == null || getClass() != o.getClass()) return false;
41. Inventory inventory = (Inventory) o;
42. return Objects.equals(products, inventory.products);
43. }
44.
45. @Override
46. public int hashCode() {
47. return Objects.hash(products);
48. }
49.
50. @Override
51. public String toString() {
52. return "Inventory{" +
53. "products=" + products +
54. '}';
55. }
56.}
集合準(zhǔn)備就緒后，讓我們創(chuàng)建存儲(chǔ)庫(kù)。要使用我們的 Inventory 類，我們可以使用 CDI 中的 Inject 注釋。我們需要將此操作提交到將要更改此集合的每個(gè)操作。對(duì)于任何可以更改清單的方法，都有Store注解為我們自動(dòng)處理它。
1.public interface ProductRepository
2.{
3. CollectiongetAll();
4.
5. Product save(Product item);
6.
7. OptionalfindById(long id);
8.
9. void deleteById(long id);
10.}
11.
12.
13.@ApplicationScoped
14.public class ProductRepositoryStorage implements ProductRepository {
15. private static final Logger LOGGER = Logger.getLogger(ProductRepositoryStorage.class.getName());
16.
17. @Inject
18. private Inventory inventory;
19.
20. @Override
21. public CollectiongetAll() {
22. return this.inventory.getProducts();
23. }
24.
25. @Override
26. @Store
27. public Product save(final Product item) {
28. this.inventory.add(item);
29. return item;
30. }
31.
32. @Override
33. public OptionalfindById(final long id) {
34. LOGGER.info("Finding the item by id: " + id);
35. return this.inventory.findById(id);
36. }
37.
38. @Override
39. @Store
40. public void deleteById(final long id) {
41. this.inventory.deleteById(id);
42. }
43.}
最后一步是將此產(chǎn)品公開(kāi)為 Rest API。然后，我們將使用Jakarta EE API返回MicroProfile：JAX-RS。接下來(lái)，我們將使用 MicroProfile 創(chuàng)建 Open API 文檔。
1.@RequestScoped
2.@Path("products")
3.@Consumes(MediaType.APPLICATION_JSON)
4.@Produces(MediaType.APPLICATION_JSON)
5.public class ProductController
6.{
7. @Inject
8. private ProductRepository repository;
9.
10. // TODO don't worried about pagination
11. @GET
12. public CollectiongetAll()
13. {
14. return this.repository.getAll();
15. }
16.
17. @GET
18. @Path("{id}")
19. @Operation(summary = "Find a product by id", description = "Find a product by id")
20. public Product findById(@PathParam("id") final long id)
21. {
22. return this.repository.findById(id).orElseThrow(
23. () -> new WebApplicationException("There is no product with the id " + id, Response.Status.NOT_FOUND));
24. }
25.
26. @POST
27. public Response insert(final Product product)
28. {
29. return Response.status(Response.Status.CREATED).entity(this.repository.save(product)).build();
30. }
31.
32. @DELETE
33. @Path("{id}")
34. public Response delete(@PathParam("id") final long id){
35. this.repository.deleteById(id);
36. return Response.status(Response.Status.NO_CONTENT).build();
37. }
38.
39.}
就是這樣！我們可以測(cè)試運(yùn)行的應(yīng)用程序并檢查結(jié)果。
1.mvn clean package
2.java -jar target/wildfly-example-bootable.jar
3.
4.curl --location --request POST 'http://localhost:8080/products/' \
5.--header 'Content-Type: application/json' \
6.--data-raw '{"id": 1, "name": "banana", "description": "a fruit", "rating": 5}'
7.
8.curl --location --request POST 'http://localhost:8080/products/' \
9.--header 'Content-Type: application/json' \
10.--data-raw '{"id": 2, "name": "watermelon", "description": "watermelon sugar ahh", "rating": 4}'
我們最終在Wildfly和Microstream之間實(shí)現(xiàn)了集成。本教程展示了兩者如何協(xié)同工作，并為你提供了一種應(yīng)對(duì)持久性問(wèn)題的新工具：Microstream。事實(shí)上，當(dāng)你想要?jiǎng)?chuàng)建微服務(wù)來(lái)超快地運(yùn)行它時(shí)，Microstream和Wildfly是很好的盟友。
譯者介紹
朱鋼，社區(qū)編輯，2021年IT影響力專家博主，阿里云專家博主，2019年CSDN博客之星20強(qiáng)，2020年騰訊云+社區(qū)優(yōu)秀作者，11年一線開(kāi)發(fā)經(jīng)驗(yàn)，曾參與獵頭服務(wù)網(wǎng)站架構(gòu)設(shè)計(jì)，企業(yè)智能客服以及大型電子政務(wù)系統(tǒng)開(kāi)發(fā)，主導(dǎo)某大型央企內(nèi)部防泄密和電子文檔安全監(jiān)控系統(tǒng)的建設(shè)，目前在北京圖伽健康從事醫(yī)療軟件研發(fā)工作。
原文標(biāo)題：??Ultra-fast Microservices: When Microstream Meets Wildfly??，作者：Otavio Santana
網(wǎng)站欄目：超快微服務(wù)：當(dāng)Microstream遇上Wildfly
分享URL：http://www.5511xx.com/article/dpiispg.html
