当前位置： 首页 > wzjs >正文

我想自己建立一个网站seo营销的策略有哪些

wzjs 2025/9/16 21:07:18
我想自己建立一个网站,seo营销的策略有哪些,高端网站开发步骤,图片制作pdf文件序 本文主要研究一下langchain4j的HTTP Client langchain4j-http-client langchain4j提供了langchain4j-http-client模块，它实现了一个HttpClient SPI（服务提供者接口），其他模块通过该接口调用LLM提供商的REST API。这意味着底…

序

本文主要研究一下langchain4j的HTTP Client

langchain4j-http-client

langchain4j提供了langchain4j-http-client模块，它实现了一个HttpClient SPI（服务提供者接口），其他模块通过该接口调用LLM提供商的REST API。这意味着底层HTTP客户端可以被自定义，通过实现HttpClient SPI，还可以集成任何其他HTTP客户端。目前，有两个现成的实现：

  • langchain4j-http-client-jdk模块中的JdkHttpClient。在例如langchain4j-open-ai等有引用的模块中默认使用
  • langchain4j-http-client-spring-restclient模块中的SpringRestClient。在例如langchain4j-open-ai-spring-boot-starter等有引用的spring boot starter中默认使用

HttpClient

langchain4j-http-client/src/main/java/dev/langchain4j/http/client/HttpClient.java

@Experimental
public interface HttpClient {/*** Executes a given HTTP request synchronously and returns the response.* This method blocks until the entire response is received.** @param request the HTTP request to be executed.* @return a {@link SuccessfulHttpResponse} containing the response data for successful HTTP requests (2XX status codes)* @throws HttpException    if the server returns a client (4XX) or server (5XX) error response* @throws RuntimeException if an unexpected error occurs during request execution (e.g., network issues, timeouts)*/SuccessfulHttpResponse execute(HttpRequest request) throws HttpException, RuntimeException;/*** Executes a given HTTP request asynchronously with server-sent events (SSE) handling.* This method returns immediately while processing continues on a separate thread.* Events are processed through the provided {@link ServerSentEventListener}.* <p>* The execution flow is as follows:* <ol>*   <li>The request is initiated asynchronously</li>*   <li>Received SSE data is parsed using the {@link DefaultServerSentEventParser}</li>*   <li>Parsed events are delivered to the listener's appropriate methods</li>*   <li>If an error occurs, {@link ServerSentEventListener#onError(Throwable)} is called</li>* </ol>* <p>* If any exception is thrown from the listener's methods, the stream processing* will be terminated and no further events will be processed.** @param request  the HTTP request to be executed.* @param listener the listener to receive parsed events and error notifications.*/default void execute(HttpRequest request, ServerSentEventListener listener) {execute(request, new DefaultServerSentEventParser(), listener);}/*** Executes a given HTTP request asynchronously with server-sent events (SSE) handling.* This method returns immediately while processing continues on a separate thread.* Events are processed through the provided {@link ServerSentEventListener}.* <p>* The execution flow is as follows:* <ol>*   <li>The request is initiated asynchronously</li>*   <li>Received SSE data is parsed using the provided parser</li>*   <li>Parsed events are delivered to the listener's appropriate methods</li>*   <li>If an error occurs, {@link ServerSentEventListener#onError(Throwable)} is called</li>* </ol>* <p>* If any exception is thrown from the listener's methods, the stream processing* will be terminated and no further events will be processed.** @param request  the HTTP request to be executed.* @param parser   the parser to process incoming server-sent events.* @param listener the listener to receive parsed events and error notifications.*/void execute(HttpRequest request, ServerSentEventParser parser, ServerSentEventListener listener);
}

HttpClient定义了execute方法，其中有一个支持ServerSentEventListener

HttpClientBuilderFactory

langchain4j-http-client/src/main/java/dev/langchain4j/http/client/HttpClientBuilderFactory.java

@Experimental
public interface HttpClientBuilderFactory {HttpClientBuilder create();
}

HttpClientBuilderFactory定义了create方法返回HttpClientBuilder

HttpClientBuilder

langchain4j-http-client/src/main/java/dev/langchain4j/http/client/HttpClientBuilder.java

@Experimental
public interface HttpClientBuilder {Duration connectTimeout();HttpClientBuilder connectTimeout(Duration timeout);Duration readTimeout();HttpClientBuilder readTimeout(Duration timeout);HttpClient build();
}

HttpClientBuilder定义了connectTimeout、readTimeout、build方法

HttpClientBuilderLoader

langchain4j-http-client/src/main/java/dev/langchain4j/http/client/HttpClientBuilderLoader.java

@Experimental
public class HttpClientBuilderLoader {public static HttpClientBuilder loadHttpClientBuilder() {Collection<HttpClientBuilderFactory> factories = loadFactories(HttpClientBuilderFactory.class);if (factories.size() > 1) {List<String> factoryNames = factories.stream().map(factory -> factory.getClass().getName()).toList();throw new IllegalStateException(String.format("Conflict: multiple HTTP clients have been found " +"in the classpath: %s. Please explicitly specify the one you wish to use.", factoryNames));}for (HttpClientBuilderFactory factory : factories) {return factory.create();}throw new IllegalStateException("No HTTP client has been found in the classpath");}
}

HttpClientBuilderLoader提供了loadHttpClientBuilder方法，它通过dev.langchain4j.spi.ServiceHelper.loadFactories方法来加载HttpClientBuilderFactory的实现类

ServiceHelper

langchain4j-core/src/main/java/dev/langchain4j/spi/ServiceHelper.java

    /*** Load all the services of a given type.** @param clazz the type of service* @param <T>   the type of service* @return the list of services, empty if none*/public static <T> Collection<T> loadFactories(Class<T> clazz) {return loadFactories(clazz, null);}/*** Load all the services of a given type.** <p>Utility mechanism around {@code ServiceLoader.load()}</p>** <ul>*     <li>If classloader is {@code null}, will try {@code ServiceLoader.load(clazz)}</li>*     <li>If classloader is not {@code null}, will try {@code ServiceLoader.load(clazz, classloader)}</li>*     </ul>** <p>If the above return nothing, will fall back to {@code ServiceLoader.load(clazz, $this class loader$)}</p>** @param clazz       the type of service* @param classLoader the classloader to use, may be null* @param <T>         the type of service* @return the list of services, empty if none*/public static <T> Collection<T> loadFactories(Class<T> clazz, /* @Nullable */ ClassLoader classLoader) {List<T> result;if (classLoader != null) {result = loadAll(ServiceLoader.load(clazz, classLoader));} else {// this is equivalent to:// ServiceLoader.load(clazz, TCCL);result = loadAll(ServiceLoader.load(clazz));}if (result.isEmpty()) {// By default, ServiceLoader.load uses the TCCL, this may not be enough in environment dealing with// classloaders differently such as OSGi. So we should try to use the classloader having loaded this// class. In OSGi it would be the bundle exposing vert.x and so have access to all its classes.result = loadAll(ServiceLoader.load(clazz, ServiceHelper.class.getClassLoader()));}return result;}

ServiceHelper是对JDK自带的ServiceLoader.load()进行了封装

langchain4j-http-client-jdk

JdkHttpClientBuilderFactory

dev/langchain4j/http/client/jdk/JdkHttpClientBuilderFactory.java

public class JdkHttpClientBuilderFactory implements HttpClientBuilderFactory {@Overridepublic JdkHttpClientBuilder create() {return JdkHttpClient.builder();}
}

JdkHttpClientBuilderFactory的create返回的是JdkHttpClientBuilder

JdkHttpClientBuilder

dev/langchain4j/http/client/jdk/JdkHttpClientBuilder.java

public class JdkHttpClientBuilder implements HttpClientBuilder {private java.net.http.HttpClient.Builder httpClientBuilder;private Duration connectTimeout;private Duration readTimeout;public java.net.http.HttpClient.Builder httpClientBuilder() {return httpClientBuilder;}public JdkHttpClientBuilder httpClientBuilder(java.net.http.HttpClient.Builder httpClientBuilder) {this.httpClientBuilder = httpClientBuilder;return this;}@Overridepublic Duration connectTimeout() {return connectTimeout;}@Overridepublic JdkHttpClientBuilder connectTimeout(Duration connectTimeout) {this.connectTimeout = connectTimeout;return this;}@Overridepublic Duration readTimeout() {return readTimeout;}@Overridepublic JdkHttpClientBuilder readTimeout(Duration readTimeout) {this.readTimeout = readTimeout;return this;}@Overridepublic JdkHttpClient build() {return new JdkHttpClient(this);}
}

JdkHttpClientBuilder的build构建的是JdkHttpClient

JdkHttpClient

dev/langchain4j/http/client/jdk/JdkHttpClient.java

public class JdkHttpClient implements HttpClient {private final java.net.http.HttpClient delegate;private final Duration readTimeout;public JdkHttpClient(JdkHttpClientBuilder builder) {java.net.http.HttpClient.Builder httpClientBuilder =getOrDefault(builder.httpClientBuilder(), java.net.http.HttpClient::newBuilder);if (builder.connectTimeout() != null) {httpClientBuilder.connectTimeout(builder.connectTimeout());}this.delegate = httpClientBuilder.build();this.readTimeout = builder.readTimeout();}public static JdkHttpClientBuilder builder() {return new JdkHttpClientBuilder();}@Overridepublic SuccessfulHttpResponse execute(HttpRequest request) throws HttpException {try {java.net.http.HttpRequest jdkRequest = toJdkRequest(request);java.net.http.HttpResponse<String> jdkResponse = delegate.send(jdkRequest, BodyHandlers.ofString());if (!isSuccessful(jdkResponse)) {throw new HttpException(jdkResponse.statusCode(), jdkResponse.body());}return fromJdkResponse(jdkResponse, jdkResponse.body());} catch (IOException | InterruptedException e) {throw new RuntimeException(e);}}@Overridepublic void execute(HttpRequest request, ServerSentEventParser parser, ServerSentEventListener listener) {java.net.http.HttpRequest jdkRequest = toJdkRequest(request);delegate.sendAsync(jdkRequest, BodyHandlers.ofInputStream()).thenAccept(jdkResponse -> {if (!isSuccessful(jdkResponse)) {listener.onError(new HttpException(jdkResponse.statusCode(), readBody(jdkResponse)));return;}SuccessfulHttpResponse response = fromJdkResponse(jdkResponse, null);listener.onOpen(response);try (InputStream inputStream = jdkResponse.body()) {parser.parse(inputStream, listener);listener.onClose();} catch (IOException e) {throw new RuntimeException(e);}}).exceptionally(throwable -> {if (throwable.getCause() instanceof HttpTimeoutException) {listener.onError(throwable);}return null;});}//......
}

JdkHttpClient的构造器创建了java.net.http.HttpClient作为delegate

langchain4j-http-client-spring-restclient

SpringRestClientBuilderFactory

dev/langchain4j/http/client/spring/restclient/SpringRestClientBuilderFactory.java

public class SpringRestClientBuilderFactory implements HttpClientBuilderFactory {@Overridepublic SpringRestClientBuilder create() {return SpringRestClient.builder();}
}

SpringRestClientBuilderFactory的create返回的是SpringRestClientBuilder

SpringRestClientBuilder

dev/langchain4j/http/client/spring/restclient/SpringRestClientBuilder.java

public class SpringRestClientBuilder implements HttpClientBuilder {private RestClient.Builder restClientBuilder;private AsyncTaskExecutor streamingRequestExecutor;private Boolean createDefaultStreamingRequestExecutor = true;private Duration connectTimeout;private Duration readTimeout;public RestClient.Builder restClientBuilder() {return restClientBuilder;}public SpringRestClientBuilder restClientBuilder(RestClient.Builder restClientBuilder) {this.restClientBuilder = restClientBuilder;return this;}public AsyncTaskExecutor streamingRequestExecutor() {return streamingRequestExecutor;}public SpringRestClientBuilder streamingRequestExecutor(AsyncTaskExecutor streamingRequestExecutor) {this.streamingRequestExecutor = streamingRequestExecutor;return this;}public Boolean createDefaultStreamingRequestExecutor() {return createDefaultStreamingRequestExecutor;}public SpringRestClientBuilder createDefaultStreamingRequestExecutor(Boolean createDefaultStreamingRequestExecutor) {this.createDefaultStreamingRequestExecutor = createDefaultStreamingRequestExecutor;return this;}@Overridepublic Duration connectTimeout() {return connectTimeout;}@Overridepublic SpringRestClientBuilder connectTimeout(Duration connectTimeout) {this.connectTimeout = connectTimeout;return this;}@Overridepublic Duration readTimeout() {return readTimeout;}@Overridepublic SpringRestClientBuilder readTimeout(Duration readTimeout) {this.readTimeout = readTimeout;return this;}@Overridepublic SpringRestClient build() {return new SpringRestClient(this);}
}

SpringRestClientBuilder的build创建的是SpringRestClient

SpringRestClient

dev/langchain4j/http/client/spring/restclient/SpringRestClient.java

public class SpringRestClient implements HttpClient {private final RestClient delegate;private final AsyncTaskExecutor streamingRequestExecutor;public SpringRestClient(SpringRestClientBuilder builder) {RestClient.Builder restClientBuilder = getOrDefault(builder.restClientBuilder(), RestClient::builder);ClientHttpRequestFactorySettings settings = ClientHttpRequestFactorySettings.DEFAULTS;if (builder.connectTimeout() != null) {settings = settings.withConnectTimeout(builder.connectTimeout());}if (builder.readTimeout() != null) {settings = settings.withReadTimeout(builder.readTimeout());}ClientHttpRequestFactory clientHttpRequestFactory = ClientHttpRequestFactories.get(settings);this.delegate = restClientBuilder.requestFactory(clientHttpRequestFactory).build();this.streamingRequestExecutor = getOrDefault(builder.streamingRequestExecutor(), () -> {if (builder.createDefaultStreamingRequestExecutor()) {return createDefaultStreamingRequestExecutor();} else {return null;}});}//......@Overridepublic SuccessfulHttpResponse execute(HttpRequest request) throws HttpException {try {ResponseEntity<String> responseEntity = toSpringRestClientRequest(request).retrieve().toEntity(String.class);return SuccessfulHttpResponse.builder().statusCode(responseEntity.getStatusCode().value()).headers(responseEntity.getHeaders()).body(responseEntity.getBody()).build();} catch (RestClientResponseException e) {throw new HttpException(e.getStatusCode().value(), e.getMessage());}}@Overridepublic void execute(HttpRequest request, ServerSentEventParser parser, ServerSentEventListener listener) {streamingRequestExecutor.execute(() -> {try {toSpringRestClientRequest(request).exchange((springRequest, springResponse) -> {int statusCode = springResponse.getStatusCode().value();if (!springResponse.getStatusCode().is2xxSuccessful()) {String body = springResponse.bodyTo(String.class);listener.onError(new HttpException(statusCode, body));return null;}SuccessfulHttpResponse response = SuccessfulHttpResponse.builder().statusCode(statusCode).headers(springResponse.getHeaders()).build();listener.onOpen(response);try (InputStream inputStream = springResponse.getBody()) {parser.parse(inputStream, listener);listener.onClose();}return null;});} catch (Exception e) {if (e.getCause() instanceof SocketTimeoutException) {listener.onError(e);}}});}}

SpringRestClient的构造器构建了org.springframework.web.client.RestClient为delegate，同时要构建了streamingRequestExecutor用于ServerSentEventListener

小结

langchain4j的langchain4j-http-client模块定义了HttpClient SPI（服务提供者接口），目前有两个现成的实现：

  • langchain4j-http-client-jdk模块中的JdkHttpClient，使用的是java.net.http.HttpClient
  • langchain4j-http-client-spring-restclient模块中的SpringRestClient，使用的是org.springframework.web.client.RestClient

doc

  • customizable-http-client

文章转载自：

http://zaTTmgNp.nbfkk.cn
http://tBZBr9nY.nbfkk.cn
http://3gQf3KFA.nbfkk.cn
http://2P1Laigz.nbfkk.cn
http://KM05QU4j.nbfkk.cn
http://9J9xB9hV.nbfkk.cn
http://IDUi3lki.nbfkk.cn
http://SfGWVzxL.nbfkk.cn
http://4MyDxEIX.nbfkk.cn
http://rDpG2HYT.nbfkk.cn
http://URGYvp0N.nbfkk.cn
http://vgIhRzEw.nbfkk.cn
http://dFYcZUoC.nbfkk.cn
http://svmImZGe.nbfkk.cn
http://BBbQp8sa.nbfkk.cn
http://ik6YHjLE.nbfkk.cn
http://YHISCqht.nbfkk.cn
http://0RqSPpeb.nbfkk.cn
http://6Ub8wKQ2.nbfkk.cn
http://f7Qbs1ut.nbfkk.cn
http://fzjuyaep.nbfkk.cn
http://XiQvVPtF.nbfkk.cn
http://N3adFO4E.nbfkk.cn
http://hRR1gOFQ.nbfkk.cn
http://V7zaIqFI.nbfkk.cn
http://SSjbSlv8.nbfkk.cn
http://n9hp2850.nbfkk.cn
http://BUyvzfIu.nbfkk.cn
http://KPHzSx8T.nbfkk.cn
http://sJjt9POI.nbfkk.cn
http://www.dtcms.com/wzjs/759103.html

相关文章：

  • 网站建设外文文献翻译外贸网站 沙盒
  • 自己做代练网站美橙网站建设经典案例
  • 用wex5可以做网站吗贵州省建设执业资格促进会网站
  • 广州达美网站建设公司海兴网站建设
  • 抚州城乡建设厅网站商标自助查询系统官网
  • 苏州公司网站建设服务自己怎么制作微信小程序
  • 协会网站信息平台建设企业建站用什么主机
  • 南京的网站制作公司多少钱要交税
  • 哈尔滨展览设计公司已矣seo排名点击软件
  • 网站的用户体验贵阳市房地产交易平台上线
  • 1号店网站网页特效濮阳网站怎么做seo
  • 杭州高端网建新站seo优化快速上排名
  • 凤山网站seovs2008不能新建网站
  • 海洋网站建设公司网站图片轮播怎么做的
  • 如何拥有一个自己的网站贵州企业网站建设公司
  • 手机网站图片切换特效广告代运营
  • 外汇自动跟单网站开发微信产品展示小程序
  • wordpress网站模版城市建设局网站
  • 注册域名之后如何做网站linux服务器WordPress建站教程
  • 桂城网站建设网站开发亮点
  • 表白网站建设源码怎么查看网站是否降权
  • 棠下手机网站建设电话广告设计专业简历
  • 有哪个网站做ic新乡建设企业网站
  • 做分销微商城网站如何开科技软件
  • 宁波p2p网站建设企业网络营销策划
  • php网站开发工资多少服务器上网站建设
  • 网站里怎样添加关键词河北建设厅网站初始密码
  • 网站制作哪家做的好青岛做网站大公司有哪些
  • 设计简单的网站做非法网站判什么邢
  • 手机在线做ppt的网站有哪些问题哪个浏览器任何网站都可以访问