maven 依賴包

	<properties>
		<spring.version>5.1.0.RELEASE</spring.version>
	</properties>

	<dependencies>
		<dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<version>3.8.1</version>
			<scope>test</
 
scope>
		</dependency>

		<dependency>
			<groupId>redis.clients</groupId>
			<artifactId>jedis</artifactId>
			<version>2.9.0</version>
		</dependency>

		<!-- Spring -->
		<dependency>
			<groupId>org.springframework</groupId>
 

			<artifactId>spring-context</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-core</artifactId>
			<version>${spring.version}</version>
 

		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-beans</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-aop</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-aspects</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework.data</groupId>
			<artifactId>spring-data-redis</artifactId>
			<version>2.1.0.RELEASE</version>
		</dependency>
	</dependencies>

Spring 配置檔案

	<!-- spring 註解配置 -->
	<context:annotation-config />
	<context:component-scan base-package="com" />
	<context:property-placeholder location="classpath:config.properties" />
	<aop:aspectj-autoproxy />

	<import resource="spring-redis.xml" />

Spring-redis.xml 配置檔案

	<!-- 以後優化查詢可配的引數 -->
	<bean id="jedistPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
	</bean>

	<bean id="redisConnectionFactory"
		class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
		p:host-name="${redis.host}" p:port="${redis.port}" p:password="${redis.pass}"
		p:pool-config-ref="jedistPoolConfig" />


	<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
		<property name="connectionFactory" ref="redisConnectionFactory" />
		<property name="defaultSerializer">
			<bean
				class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" />
		</property>
	</bean>


	<bean id="jdkSerializer"
		class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" />

	<!-- 通用訊息處理 -->
	<bean id="messageListenerTopicAll"
		class="org.springframework.data.redis.listener.adapter.MessageListenerAdapter">
		<constructor-arg>
			<bean class="com.redis.ListenMessageDelegate" />
		</constructor-arg>
		<property name="serializer" ref="jdkSerializer" />
	</bean>


	<bean id="redisContainer"
		class="org.springframework.data.redis.listener.RedisMessageListenerContainer">
		<property name="connectionFactory" ref="redisConnectionFactory" />
		<property name="taskExecutor">
			<bean
				class="org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler">
				<property name="poolSize" value="20"></property>
			</bean>
		</property>
		<property name="messageListeners">
			<map>
				<!-- 通用主題 -->
				<entry key-ref="messageListenerTopicAll">
					<list>
						<bean class="org.springframework.data.redis.listener.ChannelTopic">
							<constructor-arg value="topicAll" />
						</bean>
						<bean class="org.springframework.data.redis.listener.ChannelTopic">
							<constructor-arg value="topicLogic" />
						</bean>
					</list>
				</entry>
			</map>
		</property>
	</bean>

Redis 配置

redis.host=127.0.0.1
redis.port=6379
redis.pass=
redis.maxIdle=300
redis.maxActive=600
redis.maxWait=1000
redis.testOnBorrow=true

Delegate介面

public interface MessageDelegate {

	public void handleMessage(byte[] message);
}

Delegate實現

public class ListenMessageDelegate implements MessageDelegate {

	public void handleMessage(byte[] message) {
		//....
		System.out.println(new String(message));
	}

}

釋出訊息

/**
* 注意 message 必須是位元組流
*/
public void convertAndSendRsResponse(String channel, Object message) {
		redisTemplate.convertAndSend(channel, message);
}