在Spring Boot应用中使用Pivotal Cloud Foundry Redis和RabbitMQ服务作为VCAP服务

Question

我可以使用Pivotal上的REDIS和RABBITMQ服务。在绑定服务时，我能够获取凭证并将其用于我的Spring Boot项目的application.properties文件中。但是，我目前使用的这种配置是硬编码在application.Properties中的。为了使此配置动态化，我了解到可以使用Pivotal提供的vcap服务。

因此，我想要使用运行时凭证来访问redis和rabbimq。

以下是我的代码参考：

application.propeties

rabbitmq.host=hostname
rabbitmq.virtual-host=vhostanme
rabbitmq.username=username
rabbitmq.password=password
rabbit.mainqueue=abhi
rabbit.errorqueue=abc
redis.host=redishostname
redis.port=port
redis.password=password

我的Config类：

import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

@Component
public class Config {


    static String rabbitMqHost;
    static String rabbitMqVHost;
    static String rabbitMqUsername;
    static String rabbitMqPassword;
    static String rabbitMqMainQueue;
    static String rabbitMqErrorQueue;
    static String redisHost;
    static int redisPort;
    static String redisPassword;


    Config() {
    }


    public static String getRedisHost() {
        return redisHost;
    }

    public static void setRedisHost(String redisHost) {
        Config.redisHost = redisHost;
    }

    public static int getRedisPort() {
        return redisPort;
    }

    public static void setRedisPort(int redisPort) {
        Config.redisPort = redisPort;
    }

    public static String getRedisPassword() {
        return redisPassword;
    }

    public static void setRedisPassword(String redisPassword) {
        Config.redisPassword = redisPassword;
    }

    public static String getRabbitMqMainQueue() {
        return rabbitMqMainQueue;
    }

    public static void setRabbitMqMainQueue(String rabbitMqMainQueue) {
        Config.rabbitMqMainQueue = rabbitMqMainQueue;
    }

    public static String getRabbitMqErrorQueue() {
        return rabbitMqErrorQueue;
    }

    public static void setRabbitMqErrorQueue(String rabbitMqErrorQueue) {
        Config.rabbitMqErrorQueue = rabbitMqErrorQueue;
    }

    public static String getRabbitMqHost() {
        return rabbitMqHost;
    }

    public static void setRabbitMqHost(String rabbitMqHost) {
        Config.rabbitMqHost = rabbitMqHost;
    }

    public static String getRabbitMqVHost() {
        return rabbitMqVHost;
    }

    public static void setRabbitMqVHost(String rabbitMqVHost) {
        Config.rabbitMqVHost = rabbitMqVHost;
    }

    public static String getRabbitMqUsername() {
        return rabbitMqUsername;
    }

    public static void setRabbitMqUsername(String rabbitMqUsername) {
        Config.rabbitMqUsername = rabbitMqUsername;
    }

    public static String getRabbitMqPassword() {
        return rabbitMqPassword;
    }

    public static void setRabbitMqPassword(String rabbitMqPassword) {
        Config.rabbitMqPassword = rabbitMqPassword;
    }

    @Value("${rabbitmq.host}")
    public void setRabbitMqHosts(String url) {
        setRabbitMqHost(url);
    }

    @Value("${rabbitmq.virtual-host}")
    public void setRabbitMqVHosts(String url) {
        setRabbitMqVHost(url);
    }

    @Value("${rabbitmq.username}")
    public void setRabbitUsernames(String url) {
        setRabbitMqUsername(url);
    }

    @Value("${rabbitmq.password}")
    public void setRabbitPasswords(String url) {
        setRabbitMqPassword(url);
    }

    @Value("${rabbit.mainqueue}")
    public void setRabbitMainQueues(String url) {
        setRabbitMqMainQueue(url);
    }

    @Value("${rabbit.errorqueue}")
    public void setRabbitErrorQueues(String url) {
        setRabbitMqErrorQueue(url);
    }

    @Value("${redis.host}")
    public void setRedisHosts(String url) {
        setRedisHost(url);
    }

    @Value("${redis.port}")
    public void setRedisPorts(int url) {
        setRedisPort(url);
    }
    @Value("${redis.password}")
    public void setRedisPasswords(String url) {
        setRedisPassword(url);
    }
}

我正在使用我的MessagesConsumer类，其中我使用该配置从rabbitmq jms队列中获取消息并保存到redis中：

import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;

import javax.annotation.PostConstruct;
import javax.jms.ConnectionFactory;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.Session;

import org.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import com.es.consumer.config.Config;
import com.rabbitmq.jms.admin.RMQConnectionFactory;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisShardInfo;

@Component
public class MessagesConsumer {
    @Autowired
    JmsTemplate jmsTemplate;
    final Logger logger = LoggerFactory.getLogger(MessagesConsumer.class);

    Jedis jedis;

    JedisShardInfo shardInfo;

    @PostConstruct
    public void init() {

        shardInfo = new JedisShardInfo(Config.getRedisHost(), Config.getRedisPort());
        shardInfo.setPassword(Config.getRedisPassword());
        jedis = new Jedis(shardInfo);
        jedis.connect();
        jedis.select(2);

    }

    @Bean
    ConnectionFactory connectionFactory() {

        RMQConnectionFactory connectionFactory = new RMQConnectionFactory();
        connectionFactory.setUsername(Config.getRabbitMqUsername());
        connectionFactory.setPassword(Config.getRabbitMqPassword());
        connectionFactory.setVirtualHost(Config.getRabbitMqVHost());
        connectionFactory.setHost(Config.getRabbitMqHost());
        return connectionFactory;

    }

    @SuppressWarnings("rawtypes")
    @Scheduled(fixedRate = 1)
    public void readQueueAndSaveData() {
// take message process it and save to redis as hmset

}}

任何帮助都将不胜感激。

- Abhijeet Behare

Answer 1

有两种方法来实现这个功能。 1) 从application.properties中删除所有属性，并编写一个配置bean，该bean将为您创建RedisTemplate和RabbitTemplate bean。这些所需的工厂属性来自VCAP_SERVICES。在CF上，VCAP_SERVICES env变量将具有绑定到应用程序的服务信息。当将应用程序推送到已绑定redis、rabbit服务的空间时，它们的属性就可用于VCAP_SERVICES。因此，在代码中只需执行System.getEnv("VCAP_SERVICES")，然后解析json以获取服务详细信息以创建模板即可。

2) 从application.properties中删除属性，并使用spring cloud connector。Spring cloud有一个名为Spring Cloud Connectors的子项目，提供连接到各种云服务的实用工具。

http://cloud.spring.io/spring-cloud-connectors/spring-cloud-spring-service-connector.html#_rabbitmq

您只需要定义一个继承AbstractCloudConfig的类，如下所示：

class CloudConfig extends AbstractCloudConfig {
    @Bean
    public RabbitConnectionFactory rabbitFactory() {
        return connectionFactory().rabbitConnectionFactory("rabbit-servicename");
    }

    @Bean
    public RedisConnectionFactory redisFactory() {
        return connectionFactory().redisConnectionFactory("redis-servicename");
    }
}

如果您使用Spring，第二种方法更受欢迎，因为它需要很少的编码，并且可以轻松地切换到不同的云提供商。

- Praneeth Ramesh

---

我可以获取@Bean的依赖项吗？public RabbitConnectionFactory rabbitFactory() { return connectionFactory().rabbitConnectionFactory("rabbit-servicename"); }我尝试过的依赖项是：<dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit</artifactId> <version>1.6.8.RELEASE</version> </dependency> - Abhijeet Behare

但我想使用HMSET将数据保存在Redis中作为哈希，但我认为Redis模板不支持hmset。 - Abhijeet Behare

要使用的依赖项。 <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-cloudfoundry-connector</artifactId> </dependency> RedisTemplate可能支持HMSET。 我不确定也没有尝试过，但可以查看此链接。 http://docs.spring.io/spring-data/redis/docs/current/api/org/springframework/data/redis/connection/RedisHashCommands.html#hMSet-byte:A-java.util.Map- - Praneeth Ramesh

rabbitFactory 方法的返回类型应该是 ConnectionFactory（org.springframework.amqp.rabbit.connection.ConnectionFactory），而不是 RabbitConnectionFactory。请参考 https://github.com/spring-cloud/spring-cloud-connectors/issues/220 了解更多详情。 - Pons