配置環境

版本資訊:

Spring 4.2.8.RELEASE(其中囊括tx、webmvc、context、aop之類的)
Spring-data-jpa 1.10.5.RELEASE
Spring-data-redis 1.8.0.RELEASE
Spring-data-commons 1.12.5.RELEASE
MySQL 5.7
JDK 1.8

Maven依賴：

<!-- spring begin -->
        <dependency>
            <groupId>org.springframework</groupId
 
>
            <artifactId>spring-webmvc</artifactId>
            <version>4.2.8.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aop</artifactId>
            <version
 
>4.2.8.RELEASE</version>
        </dependency><dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jms</artifactId>
            <version>4.2.8.RELEASE</version>
        </dependency>
        <dependency
 
>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjrt</artifactId>
            <version>1.8.9</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.data</groupId>
            <artifactId>spring-data-jpa</artifactId>
            <version>1.10.5.RELEASE</version>
        </dependency>
        <!-- spring end -->
        <!-- redis start-->
        <dependency>
            <groupId>org.springframework.data</groupId>
            <artifactId>spring-data-redis</artifactId>
            <version>1.8.0.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>2.9.0</version>
        </dependency>
        <!--redis end-->

ApplicationContext.xml 配置

這裡就只新增 Redis 相關的資訊了。

<!-- 事務管理器 -->
    <bean id="MytransactionManager"          class="org.springframework.orm.jpa.JpaTransactionManager">
        <property name="entityManagerFactory" ref="MyentityManagerFactory" />
        <property name="dataSource" ref="MydataSource"/>
    </bean>

    <!-- 註解式事務 -->
    <tx:annotation-driven transaction-manager="MytransactionManager" />
    <!--MessageQueue Start-->
    <bean id="MQConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
          p:hostName="127.0.0.1" p:port="6379" p:password="password" p:usePool="true">
    </bean>
    <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"
          p:connectionFactory-ref="MQConnectionFactory"/>
    <!--JDK序列化工具-->
    <bean id="Serialization" class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" />
    <!--文字序列化工具-->
    <bean id="Stringserialization" class="org.springframework.data.redis.serializer.StringRedisSerializer" />
    <!--訂閱者-->
    <bean id="Listener" class="com.MuNineyi.messagequeue.Listener"/>

    <!--訂閱者介面卡-->
    <bean id="MessageListenerAdapter" class="org.springframework.data.redis.listener.adapter.MessageListenerAdapter">
        <property name="serializer" ref="Serialization" />
        <property name="stringSerializer" ref="Stringserialization"/>
        <property name="delegate" ref="Listener" /> <!--訂閱者/目的地-->
        <property name="defaultListenerMethod" value="receiveMessage"/> <!--預設接收方法-->
    </bean>

    <!--channelPattern 通道設定器，這裡和老版本是不同的-->
    <bean id="Topic" class="org.springframework.data.redis.listener.PatternTopic" beans:pattern="identity"/>

    <!--裝箱，這裡和老版本是不同的-->
    <bean id="RedisMessageListenerContainer" class="org.springframework.data.redis.listener.RedisMessageListenerContainer">
        <property name="connectionFactory" ref="MQConnectionFactory"/>
        <property name="topicSerializer" ref="Stringserialization"/> <!--通道序列化-->
        <property name="messageListeners">
            <map key-type="org.springframework.data.redis.connection.MessageListener" value-type="org.springframework.data.redis.listener.PatternTopic">
                <entry key-ref="MessageListenerAdapter"  value-ref="Topic"/>
            </map>
        </property>
    </bean>
    <!--MessageQueue End-->

程式碼實現

訊息傳遞類(訊息實體)

public class Message{
    private String name;
    private String age;
    private String liveCity;
    //相關的 get、set 方法
}

Sender 傳送者

這裡可以寫成介面的形式,方便呼叫

@Service("Service")
public class Sender{

    @Qualifier(value = "redisTemplate")
    private RedisTemplate redisTemplate;

    public void sendMessage(String channel, Serializable message) {
        redisTemplate.convertAndSend(channel, message);
    }

    public RedisTemplate getRedisTemplate() {
        return redisTemplate;
    }

    public void setRedisTemplate(RedisTemplate redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    public void getInformationFromOtherAPI(String name, String age, String liveCity) throws InterruptedException {
        Message message = new Message();
        message.setName(name);
        message.setAge(age);
        message.setLiveCity(liveCity);
        sendMessage("identity ", message);
    }
}

Listener 訂閱者

@Service("Listener")
public class Listener{

    @Autowired
    private MiddleService middleService;

    /**
     * 訂閱者
     * @param message
     */
    public void receiveMessage(Serializable message) {
       if (message instanceof Message){
           Message message = (Message) message;
        System.out.println(message.getName()+message.getAge()+message.getLiveCity());
       }
    }
}

簡單的程式碼實現已經完成了

呼叫 getInformationFromOtherAPI(), 就可以實現將資訊填入訊息佇列中。

下一篇會說一下由於JPA提交事務慢，導致訊息佇列找不到剛提交到資料庫的資訊的問題。