Micronaut 創(chuàng)建客戶端

2023-03-01 17:46 更新

如前所述，Micronaut 包括一個(gè) HTTP 服務(wù)器和一個(gè) HTTP 客戶端。提供了一個(gè)低級(jí)別的 HTTP 客戶端，您可以使用它來(lái)測(cè)試在上一節(jié)中創(chuàng)建的 HelloController。

Testing Hello World

Java Groovy Kotlin

import io.micronaut.http.HttpRequest;
import io.micronaut.http.client.HttpClient;
import io.micronaut.http.client.annotation.Client;
import io.micronaut.runtime.server.EmbeddedServer;
import io.micronaut.test.extensions.junit5.annotation.MicronautTest;
import org.junit.jupiter.api.Test;

import jakarta.inject.Inject;

import static org.junit.jupiter.api.Assertions.assertEquals;

@MicronautTest
public class HelloControllerSpec {

    @Inject
    EmbeddedServer server; // (1)

    @Inject
    @Client("/")
    HttpClient client; // (2)

    @Test
    void testHelloWorldResponse() {
        String response = client.toBlocking() // (3)
                .retrieve(HttpRequest.GET("/hello"));
        assertEquals("Hello World", response); // (4)
    }
}

import io.micronaut.http.HttpRequest
import io.micronaut.http.client.HttpClient
import io.micronaut.http.client.annotation.Client
import io.micronaut.runtime.server.EmbeddedServer
import io.micronaut.test.extensions.spock.annotation.MicronautTest
import spock.lang.Specification

import jakarta.inject.Inject

@MicronautTest
class HelloControllerSpec extends Specification {

    @Inject
    EmbeddedServer embeddedServer // (1)

    @Inject
    @Client("/")
    HttpClient client // (2)

    void "test hello world response"() {
        expect:
            client.toBlocking() // (3)
                    .retrieve(HttpRequest.GET('/hello')) == "Hello World" // (4)
    }
}

import io.micronaut.http.client.HttpClient
import io.micronaut.http.client.annotation.Client
import io.micronaut.runtime.server.EmbeddedServer
import io.micronaut.test.extensions.junit5.annotation.MicronautTest
import org.junit.jupiter.api.Assertions.assertEquals
import org.junit.jupiter.api.Test
import jakarta.inject.Inject

@MicronautTest
class HelloControllerSpec {

    @Inject
    lateinit var server: EmbeddedServer // (1)

    @Inject
    @field:Client("/")
    lateinit var client: HttpClient // (2)

    @Test
    fun testHelloWorldResponse() {
        val rsp: String = client.toBlocking() // (3)
                .retrieve("/hello")
        assertEquals("Hello World", rsp) // (4)
    }
}

EmbeddedServer 配置為共享測(cè)試域
還定義了一個(gè) HttpClient 實(shí)例共享字段
測(cè)試使用 toBlocking() 方法進(jìn)行阻塞調(diào)用
retrieve 方法將控制器響應(yīng)作為字符串返回

除了低級(jí)客戶端之外，Micronaut 還具有一個(gè)聲明式的編譯時(shí) HTTP 客戶端，由 Client 注釋提供支持。

要?jiǎng)?chuàng)建客戶端，請(qǐng)創(chuàng)建一個(gè)使用@Client 注釋的接口，例如：

src/main/java/hello/world/HelloClient.java

Java Groovy Kotlin

import io.micronaut.http.MediaType;
import io.micronaut.http.annotation.Get;
import io.micronaut.http.client.annotation.Client;
import org.reactivestreams.Publisher;
import io.micronaut.core.async.annotation.SingleResult;

@Client("/hello") // (1)
public interface HelloClient {

    @Get(consumes = MediaType.TEXT_PLAIN) // (2)
    @SingleResult
    Publisher<String> hello(); // (3)
}

import io.micronaut.http.annotation.Get
import io.micronaut.http.client.annotation.Client
import org.reactivestreams.Publisher
import io.micronaut.core.async.annotation.SingleResult

@Client("/hello") // (1)
interface HelloClient {

    @Get(consumes = MediaType.TEXT_PLAIN) // (2)
    @SingleResult
    Publisher<String> hello() // (3)
}

import io.micronaut.http.MediaType
import io.micronaut.http.annotation.Get
import io.micronaut.http.client.annotation.Client
import io.micronaut.core.async.annotation.SingleResult
import org.reactivestreams.Publisher

@Client("/hello") // (1)
interface HelloClient {

    @Get(consumes = [MediaType.TEXT_PLAIN]) // (2)
    @SingleResult
    fun hello(): Publisher<String>  // (3)
}

@Client 注釋與一個(gè)值一起使用，該值是當(dāng)前服務(wù)器的相對(duì)路徑
服務(wù)器上使用的相同@Get 注釋用于定義客戶端映射
返回帶有從服務(wù)器讀取的值的帶有 SingleResult 注釋的 Publisher

要測(cè)試 HelloClient，請(qǐng)從與服務(wù)器關(guān)聯(lián)的 ApplicationContext 中檢索它：

Testing HelloClient

Java Groovy Kotlin

import io.micronaut.test.extensions.junit5.annotation.MicronautTest;
import org.junit.jupiter.api.Test;
import io.micronaut.core.async.annotation.SingleResult;

import jakarta.inject.Inject;
import reactor.core.publisher.Mono;

import static org.junit.jupiter.api.Assertions.assertEquals;

@MicronautTest // (1)
public class HelloClientSpec  {

    @Inject
    HelloClient client; // (2)

    @Test
    public void testHelloWorldResponse(){
        assertEquals("Hello World", Mono.from(client.hello()).block());// (3)
    }
}

import io.micronaut.test.extensions.spock.annotation.MicronautTest
import reactor.core.publisher.Mono
import spock.lang.Specification

import jakarta.inject.Inject

@MicronautTest // (1)
class HelloClientSpec extends Specification {

    @Inject HelloClient client // (2)

    void "test hello world response"() {
        expect:
        Mono.from(client.hello()).block() == "Hello World" // (3)
    }

}

import io.micronaut.context.annotation.Property
import io.micronaut.test.extensions.junit5.annotation.MicronautTest
import org.junit.jupiter.api.Assertions.assertEquals
import org.junit.jupiter.api.Test
import jakarta.inject.Inject
import reactor.core.publisher.Mono


@MicronautTest // (1)
class HelloClientSpec {

    @Inject
    lateinit var client: HelloClient // (2)

    @Test
    fun testHelloWorldResponse() {
        assertEquals("Hello World", Mono.from(client.hello()).block())// (3)
    }
}

@MicronautTest 注解定義測(cè)試
HelloClient 是從 ApplicationContext 注入的
使用 Project Reactor Mono::block 方法調(diào)用客戶端

Client 注釋在編譯時(shí)自動(dòng)為您生成一個(gè)實(shí)現(xiàn)，無(wú)需使用代理或運(yùn)行時(shí)反射。

Client 注解非常靈活。

以上內(nèi)容是否對(duì)您有幫助：

← Micronaut 設(shè)置IDE

Micronaut 部署應(yīng)用程序 →

寫(xiě)筆記

我要補(bǔ)充