消费者驱动的契约测试_告诉我们您想要什么，我们将做到：消费者驱动的合同测试消息传递...

雨点打透心脏的1/2处 2023-02-25 04:56 9阅读 0赞

消费者驱动的契约测试

相当早以前，我们从[REST（ful）][REST_ful] Web API的角度讨论了[消费者驱动的合同测试][Link 1] ，尤其是将其投射到Java（ [JAX-RS 2.0][]规范）的角度。 可以公平地说，至少在公共API方面， [REST][REST_ful]仍在Web API领域占据主导地位，但是向[微服务][Link 2]或/和基于服务的体系结构的转变正在Swift改变力量的一致性。 这种破坏性趋势之一是[消息传递][Link 3] 。

现代的[REST（ful）][REST_ful] API主要通过[HTTP 1.1][]协议实现，并受其请求/响应通信样式的限制。 这里提供了[HTTP / 2的][HTTP _ 2] [帮助，][Link 4]但并不是每个用例都适合此通信模型。 通常，该工作可以异步执行，并且可以稍后将其完成的事实广播给感兴趣的各方。 这就是大多数事物在现实生活中的工作方式，而使用[消息传递][Link 3]是对此的完美答案。

[消息传递][Link 3]空间确实挤满了惊人数量的[消息代理][Link 5]和可用的无[代理][Link 5]选项。 我们将不讨论这个问题，而是关注另一个棘手的主题：消息契约。 生产者发出消息或事件后，它将进入队列/主题/频道，准备被使用。 它在这里停留了一段时间。 显然，生产者知道它所发布的内容，但是消费者呢？ 他们怎么知道会发生什么？

此刻，我们许多人会大喊：使用基于模式的序列化！ 的确， [Apache Avro][] ， [Apache Thrift][] ， [协议缓冲区][Link 6] ， [消息包][Link 7] …可以解决这个问题。 归根结底，此类消息和事件以及[REST（ful）][REST_ful] Web API（如果有[）][REST_ful]将成为提供者合同的一部分，并且必须随着时间的推移进行通信和发展，而又不会破坏消费者。 但是……您会惊讶地发现，有多少组织在[JSON中][JSON]发现了他们的必杀技，并使用它来传递消息和事件， [从而][Link 8]向消费者扔出这样的[垃圾][Link 8] ，而没有任何模式！ 在这篇文章中，我们将研究消费者驱动的合同测试技术如何在这种情况下为我们提供帮助。

让我们考虑一个简单的系统，该系统具有两项服务，即**订购服务**和**货运服务** 。 **订单服务**将消息/事件发布到消息队列，然后**运货服务**从那里使用它们。

![format_png][]

由于**Order Service**是用Java实现的，因此事件只是POJO类，在使用大量库之一到达消息代理之前，序列化为[JSON][] 。 **OrderConfirmed**是此类事件之一。

public class OrderConfirmed { 
         private UUID orderId; 
         private UUID paymentId; 
         private BigDecimal amount; 
         private String street; 
         private String city; 
         private String state; 
         private String zip; 
         private String country;  }

通常情况下， **Shipment Service**团队会交出示例[JSON][]代码片段，或者指出一些文档片段或参考Java类，基本上就是这样。 在确保他们的解释正确无误且所需信息消息不会突然消失的同时，货运**服务**团队如何启动整合工作？ [以消费者为导向的合同测试][Link 9]得以营救！

**Shipment Service**团队可以（并且应该）开始针对**OrderConfirmed**消息编写测试用例，并嵌入他们所拥有的知识，而我们的老朋友[Pact][]框架（准确地说，是[Pact JVM][] ）是实现此目的的正确工具。 那么测试用例可能是什么样子？

public class OrderConfirmedConsumerTest { 
         private static final String PROVIDER_ID = "Order Service" ; 
         private static final String CONSUMER_ID = "Shipment Service" ;     
         @Rule 
         public MessagePactProviderRule provider = new MessagePactProviderRule( this ); 
         private byte [] message; 
         @Pact (provider = PROVIDER_ID, consumer = CONSUMER_ID) 
         public MessagePact pact(MessagePactBuilder builder) { 
             return builder 
                 .given( "default" ) 
                 .expectsToReceive( "an Order confirmation message" ) 
                 .withMetadata(Map.of( "Content-Type" , "application/json" )) 
                 .withContent( new PactDslJsonBody() 
                     .uuid( "orderId" ) 
                     .uuid( "paymentId" ) 
                     .decimalType( "amount" ) 
                     .stringType( "street" ) 
                     .stringType( "city" ) 
                     .stringType( "state" ) 
                     .stringType( "zip" ) 
                     .stringType( "country" )) 
                 .toPact(); 
         } 
         @Test 
         @PactVerification (PROVIDER_ID) 
         public void test() throws Exception { 
             Assert.assertNotNull(message); 
         } 
         public void setMessage( byte [] messageContents) { 
             message = messageContents; 
         }  }

它非常简单明了，没有添加任何样板。 测试用例是根据**OrderConfirmed**消息的[JSON][]表示而设计的。 但是我们还只是半途而废， **货运** **服务**团队应该以某种方式将他们的期望回馈给**订购服务，**以便生产者可以跟踪谁以及如何消费**OrderConfirmed**消息。 [Pact][]测试工具通过将每个[JUnit][]测试用例中的pact文件（一组协议或pact）生成到**“ target / pacs”**文件夹中来解决此问题。 下面是运行**OrderConfirmedConsumerTest**测试套件后生成的**Shipment Service-Order Service.json** pact文件的**示例** 。

{ 
       "consumer" : { 
         "name" : "Shipment Service" 
       }, 
       "provider" : { 
         "name" : "Order Service" 
       }, 
       "messages" : [ 
         { 
           "description" : "an Order confirmation message" , 
           "metaData" : { 
             "contentType" : "application/json" 
           }, 
           "contents" : { 
             "zip" : "string" , 
             "country" : "string" , 
             "amount" : 100 , 
             "orderId" : "e2490de5-5bd3-43d5-b7c4-526e33f71304" , 
             "city" : "string" , 
             "paymentId" : "e2490de5-5bd3-43d5-b7c4-526e33f71304" , 
             "street" : "string" , 
             "state" : "string" 
           }, 
           "providerStates" : [ 
             { 
               "name" : "default" 
             } 
           ], 
           "matchingRules" : { 
             "body" : { 
               "$.orderId" : { 
                 "matchers" : [ 
                   { 
                     "match" : "regex" , 
                     "regex" : "[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}" 
                   } 
                 ], 
                 "combine" : "AND" 
               }, 
               "$.paymentId" : { 
                 "matchers" : [ 
                   { 
                     "match" : "regex" , 
                     "regex" : "[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}" 
                   } 
                 ], 
                 "combine" : "AND" 
               }, 
               "$.amount" : { 
                 "matchers" : [ 
                   { 
                     "match" : "decimal" 
                   } 
                 ], 
                 "combine" : "AND" 
               }, 
               "$.street" : { 
                 "matchers" : [ 
                   { 
                     "match" : "type" 
                   } 
                 ], 
                 "combine" : "AND" 
               }, 
               "$.city" : { 
                 "matchers" : [ 
                   { 
                     "match" : "type" 
                   } 
                 ], 
                 "combine" : "AND" 
               }, 
               "$.state" : { 
                 "matchers" : [ 
                   { 
                     "match" : "type" 
                   } 
                 ], 
                 "combine" : "AND" 
               }, 
               "$.zip" : { 
                 "matchers" : [ 
                   { 
                     "match" : "type" 
                   } 
                 ], 
                 "combine" : "AND" 
               }, 
               "$.country" : { 
                 "matchers" : [ 
                   { 
                     "match" : "type" 
                   } 
                 ], 
                 "combine" : "AND" 
               } 
             } 
           } 
         } 
       ], 
       "metadata" : { 
         "pactSpecification" : { 
           "version" : "3.0.0" 
         }, 
         "pact-jvm" : { 
           "version" : "4.0.2" 
         } 
       }  }

**发货服务**团队的下一步是与**订单服务**团队共享此契约文件，以便这些人可以在其测试套件中运行提供方的[契约][Pact]验证。

@RunWith (PactRunner. class )  @Provider (OrderServicePactsTest.PROVIDER_ID)  @PactFolder ( "pacts" @PactFolder "pacts" )  public class OrderServicePactsTest { 
         public static final String PROVIDER_ID = "Order Service" ; 
         @TestTarget 
         public final Target target = new AmqpTarget(); 
         private ObjectMapper objectMapper;     
         @Before 
         public void setUp() { 
             objectMapper = new ObjectMapper(); 
         } 
         @State ( "default" ) 
         public void toDefaultState() { 
         }     
         @PactVerifyProvider ( "an Order confirmation message" ) 
         public String verifyOrderConfirmed() throws JsonProcessingException { 
             final OrderConfirmed order = new OrderConfirmed();         
             order.setOrderId(UUID.randomUUID()); 
             order.setPaymentId(UUID.randomUUID()); 
             order.setAmount( new BigDecimal( "102.33" )); 
             order.setStreet( "1203 Westmisnter Blvrd" ); 
             order.setCity( "Westminster" ); 
             order.setCountry( "USA" ); 
             order.setState( "MI" ); 
             order.setZip( "92239" ); 
             return objectMapper.writeValueAsString(order); 
         }  }

测试工具从**@PactFolder中**选取所有的pact文件，并针对**@TestTarget**进行测试，在这种情况下，我们将接线提供的**AmqpTarget** ，但您可以轻松插入自己的特定目标。

基本上就是这样！ 消费者（ **装运服务** ）在测试用例中表达了他们的期望，并以契约文件的形式与生产者（ **订购服务** ）共享了他们的期望。 生产者有自己的一组测试，以确保其模型符合消费者的观点。 双方可以继续独立发展，并相互信任，只要条约不受到谴责（希望永远不会）。

公平地说， [Pact][]并不是进行[消费者驱动的合同测试][Link 9]的唯一选择，在即将发布的帖子（已经开始工作）中，我们将讨论另一个出色的选择，即[Spring Cloud Contract][] 。

直到今天，完整的项目资源都可以在[Github上找到][Github] 。

> 翻译自: [https://www.javacodegeeks.com/2019/11/tell-us-what-you-want-and-we-will-make-it-so-consumer-driven-contract-testing-for-messaging.html][https_www.javacodegeeks.com_2019_11_tell-us-what-you-want-and-we-will-make-it-so-consumer-driven-contract-testing-for-messaging.html]

消费者驱动的契约测试

[REST_ful]: https://en.wikipedia.org/wiki/Representational_state_transfer
[Link 1]: https://aredko.blogspot.com/2016/11/keep-your-promises-contract-based.html
[JAX-RS 2.0]: https://jax-rs-spec.java.net/
[Link 2]: https://en.wikipedia.org/wiki/Microservices
[Link 3]: https://en.wikipedia.org/wiki/Message_queue
[HTTP 1.1]: https://en.wikipedia.org/wiki/Hypertext_Transfer_Protocol
[HTTP _ 2]: https://en.wikipedia.org/wiki/HTTP/2
[Link 4]: https://www.mnot.net/blog/2019/10/13/h2_api_multiplexing
[Link 5]: https://en.wikipedia.org/wiki/Message_broker
[Apache Avro]: https://avro.apache.org/
[Apache Thrift]: https://thrift.apache.org/
[Link 6]: https://developers.google.com/protocol-buffers
[Link 7]: https://msgpack.org/index.html
[JSON]: https://en.wikipedia.org/wiki/JSON
[Link 8]: https://en.wikipedia.org/wiki/Character_large_object
[format_png]: /images/20230209/743ad09fc49a46a6a2cc5e280541f799.png
[Link 9]: https://martinfowler.com/articles/consumerDrivenContracts.html
[Pact]: https://docs.pact.io/
[Pact JVM]: https://github.com/DiUS/pact-jvm
[JUnit]: https://junit.org/
[Spring Cloud Contract]: https://spring.io/projects/spring-cloud-contract
[Github]: https://github.com/reta/consumer-driven-contract-messaging-pact
[https_www.javacodegeeks.com_2019_11_tell-us-what-you-want-and-we-will-make-it-so-consumer-driven-contract-testing-for-messaging.html]: https://www.javacodegeeks.com/2019/11/tell-us-what-you-want-and-we-will-make-it-so-consumer-driven-contract-testing-for-messaging.html