Spring集成

Question

我是spring集成和缓存新手，想知道如何将从出站网关接收到的对象添加到缓存中。无法确定所需的配置。

从以下配置，我从rest api收到的对象正在被记录：

INFO：com.domain.IpAddress@74589991

我计划使用ehcache/caffiene，任何提示都会有帮助。

<int:channel id="requestChannel"/>
<int:channel id="outboundChannel"/> 
<int:channel id="replyChannel"/>
<int:channel id="autoCompleteJsonResponseChannel"/>

<int:gateway id="restResponseService" default-request-channel="requestChannel" service-interface="com.domain.service.RestResponseService" />

<int-http:outbound-gateway id="out" request-channel="requestChannel"
    http-method="GET"
    url="https://api.ipify.org/?format=json"
    expected-response-type="java.lang.String"   
reply-channel="autoCompleteJsonResponseChannel"
/>

<int:json-to-object-transformer
input-channel="autoCompleteJsonResponseChannel"
type="com.domain.IpAddress"
output-channel="outboundChannel" /> 

<int:logging-channel-adapter id="outboundChannel" level="INFO"/>

编辑2：

现在，我按照建议更改了出站网关：

<int-http:outbound-gateway id="out" request-channel="requestChannel"
    http-method="GET"
    url="https://api.ipify.org/?format=json"
    expected-response-type="java.lang.String"
    reply-channel="autoCompleteJsonResponseChannel">
    <int-http:request-handler-advice-chain>
       <cache:advice>
           <cache:caching cache="myCache">
               <cache:cacheable method="getCurrentIpAddress" />
           </cache:caching>
       </cache:advice>
    </int-http:request-handler-advice-chain>
</int-http:outbound-gateway>

并将ehache配置定义如下：

<bean id="cacheManager" class="org.springframework.cache.ehcache.EhCacheCacheManager" >
        <property name="cacheManager" ref="ehcache" />
    </bean>
    <!-- Ehcache library setup -->
    <bean id="ehcache" class="org.springframework.cache.ehcache.EhCacheManagerFactoryBean" >
        <property name="configLocation" value="classpath:ehcache.xml" />
        <property name="shared" value="true"/>      
    </bean>

在我的服务类中，定义了可缓存的方法：

package com.domain.service;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.CacheEvict;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;

import com.domain.IpAddress;
import com.domain.RestResponse;

@Service("restResponseService")
public class RestResponseServiceImpl implements RestResponseService{

    @Autowired
    private IpAddress ipAddress;
    @Cacheable("myCache")
    public IpAddress getCurrentIpAddress(String name) {
        // TODO Auto-generated method stub
        return ipAddress;
    }

    @CacheEvict(value = "myCache", allEntries = true)
    public void refreshAllResults() {
        // TODO Auto-generated method stub

    }
}

但缓存仍然不起作用。我错过了什么。

Answer 1

您可以在网关中执行以下操作：

<int-http:outbound-gateway>
    <int-http:request-handler-advice-chain>
            <cache:advice>
                <cache:caching cache="foo">
                    <cache:cacheable method="handle*Message" key="#a0.payload"/>
                </cache:caching>
            </cache:advice>
    </int-http:request-handler-advice-chain>
</int-http:outbound-gateway>

换句话说，因为Spring中的缓存完全基于AOP，所以要弄清楚请求-处理程序-建议-链可以使用任何建议实现并不复杂。在这种情况下，我们制作