主页 / user-642680

D-Dᴙum's questions

Martin Hope
D-Dᴙum
Asked: 2024-12-08 07:05:48 +0800 CST
  • 5

@MessagingGateway允许defaultRequestChannel使用属性占位符${} 来设置注释：

@MessagingGateway(defaultRequestChannel = "${gateway.request.channel}")
public interface MessageGateway {

    @Gateway(requestTimeout = 2000)
    void sendListing(List<Path> entries);
}

但我无法对@Gateway注释进行类似操作：

@MessagingGateway
public interface MessageGateway {

    @Gateway(requestTimeout = 2000, requestChannel = "${gateway.request.channel}") // invalid
    void sendListing(List<Path> entries);
}

类似地，我无法使用属性占位符或 SpEl 动态设置 ServiceActivator inputChannel。outputChannel

我是否需要ServiceActivator使用手动配置ServiceActivatingHandler？

spring-integration
Martin Hope
D-Dᴙum
Asked: 2023-10-24 21:52:06 +0800 CST
  • 5

当我提取各个步骤并单独执行它们时，我创建的反应器变换函数不会给出相同的结果。

我有包含价格类型列表的 DTO 记录。

public record CarrierDto(MetaData metaData, List<Daily> dailySeries) {

    public record MetaData(String name, String information) {};
    public record Daily(String date, Integer price) {};
}

Mono<CarrierDto>我想从a中提取Flux<Daily>然后将其转换为Flux<Price>.

@Table("price")
public record Price (
        @Column("p_date") String date,
        @Column("p_price") Integer price) {
}

为了进行这种转换，我有这个功能：

static Function<Mono<CarrierDto>, Flux<Price>> transform = carrierDtoMono ->
            carrierDtoMono.map(CarrierDto::dailySeries)
                    .flatMapMany(Flux::fromIterable)
                    .map(daily -> new Price(daily.date(), daily.price()));

然而，当我尝试使用此功能时，订阅时仅给出一个价格。如果我提取每个单独的步骤并执行提供的所有价格。例如这个测试类：

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

import java.util.Arrays;
import java.util.List;
import java.util.function.Function;

public class TestMain {

    static Function<Mono<CarrierDto>, Flux<Price>> transform = carrierDtoMono ->
            carrierDtoMono.map(CarrierDto::dailySeries)
                    .flatMapMany(Flux::fromIterable)
                    .map(daily -> new Price(daily.date(), daily.price()));

    public static void main(String[] args) {
        final CarrierDto dto = new CarrierDto(new CarrierDto.MetaData("Test", "Test information"),
                Arrays.asList(new CarrierDto.Daily("2023-01-01", 100),
                        new CarrierDto.Daily("2023-01-02", 101),
                        new CarrierDto.Daily("2023-01-03", 102),
                        new CarrierDto.Daily("2023-01-04", 103)));

        System.out.println("Using Transform function.");
        Mono.just(dto)
                .transform(transform)
                .subscribe(price -> System.out.println(String.format("Date: %s Price: %d", price.date(), price.price())));

        System.out.println("Without transform function.");

        final Mono<List<CarrierDto.Daily>> monoDailySeries = Mono.just(dto).map(CarrierDto::dailySeries);
        final Flux<CarrierDto.Daily> dailyFlux = monoDailySeries.flatMapMany(Flux::fromIterable);
        final Flux<Price> priceFlux = dailyFlux.map(daily -> new Price(daily.date(), daily.price()));

        priceFlux.subscribe(price -> System.out.println(String.format("Date: %s Price: %d", price.date(), price.price())));
    }
}

给出结果：

Using Transform function.
Date: 2023-01-01 Price: 100
Without transform function.
Date: 2023-01-01 Price: 100
Date: 2023-01-02 Price: 101
Date: 2023-01-03 Price: 102
Date: 2023-01-04 Price: 103

为什么结果不同？

java