在PWS上使用SpringCloud/Netflix堆栈进行蓝色/绿色部署的典型方法是什么？

Question

我正在尝试一种设置，该设置非常类似于此处图像中详细介绍的设置：https://raw.githubusercontent.com/Oreste-Luci/netflix-oss-example/master/netflix-oss-example.png

在我的设置中，我使用的是客户端应用程序（https://www.joedog.org/siege-home/），代理（Zuul），发现服务（Eureka）和简单的微服务。一切都部署在PWS上。

我想在不停机的情况下从一个版本的简单微服务迁移到下一个版本。最初，我从这里描述的技术开始:https://docs . cloud foundry . org/dev guide/deploy-apps/blue-green . html

在我看来，这种方法与像Eureka这样的发现服务并不“兼容”。事实上，我的服务的新版本已在Eureka注册，甚至在我可以重新映射所有路由(CF路由器)之前就接收了流量。

这让我想到了另一种方法，在这种方法中，我依赖于Spring Cloud/Netflix中的故障切换机制：

1. 我启动了服务的新（向后兼容）版本。
2. 当这个版本被Zuul/Eureka选中时，它开始获得50%的流量。
3. 一旦我确认新版本正常工作，我就会删除“旧”实例。（我只需单击PWS中的“停止”按钮）

据我所知，Zuul在幕后使用Ribbon(负载平衡),所以在那一瞬间，旧实例仍在Eureka，但实际上正在关闭，我希望在新实例上重试，而不会对客户端产生任何影响。

然而，我的假设是错误的。我的客户端出现了502个错误：

Lifting the server siege...      done.

Transactions:               5305 hits
Availability:              99.96 %
Elapsed time:              59.61 secs
Data transferred:          26.06 MB
Response time:              0.17 secs
Transaction rate:          89.00 trans/sec
Throughput:             0.44 MB/sec
Concurrency:               14.96
Successful transactions:        5305
Failed transactions:               2
Longest transaction:            3.17
Shortest transaction:           0.14

我申请的一部分.yml

server:
  port: ${PORT:8765}

info:
  component: proxy

ribbon:
  MaxAutoRetries: 2   # Max number of retries on the same server (excluding the first try)
  MaxAutoRetriesNextServer: 2 # Max number of next servers to retry (excluding the first server)
  OkToRetryOnAllOperations: true # Whether all operations can be retried for this client
  ServerListRefreshInterval: 2000 # Interval to refresh the server list from the source
  ConnectTimeout: 3000 # Connect timeout used by Apache HttpClient
  ReadTimeout: 3000 # Read timeout used by Apache HttpClient

hystrix:
  threadpool:
      default:
        coreSize: 50
        maxQueueSize: 100
        queueSizeRejectionThreshold: 50
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 10000

我不知道哪里出了问题。

这是技术问题吗？

还是我做了错误的假设（我确实在某个地方读到过帖子无论如何都不会重试，我真的不明白）？

我很想听听你是怎么做到的。

谢了安迪

Answer 1

我也想知道这一点。我不会声称使用过“愤怒的春云”。我刚刚尝试了一段时间。

假设:我们假设所有实例状态的真实来源都存储在Eureka中，那么Eureka应该是我们的操作控制机制。我们可以使用Eureka通过将实例状态设置为< code>OUT_OF_SERVICE来使实例停止服务。当Ribbon刷新其服务器列表时，它不会使用这些停止服务的实例。Eureka为查询实例和设置实例状态提供了一个REST API。太好了。

问题是：如何识别哪些实例在蓝色组中，哪些实例在绿色组中？

我在想...Eureka为每个实例提供了一个元数据地图。假设在构建/烘焙步骤中，我们在元数据映射中设置了一个版本id？我们可以使用Git提交Id或者某种语义版本控制方案或者其他什么。好了，现在我可以查看Eureka元数据，并在给定版本值的情况下识别蓝色和绿色实例。我们可以使用属性设置每个服务中的元数据值。

eureka.instance.metadataMap.version=8675309

如果我们能告诉尤里卡就好了。“取消FUBAR服务和8675309版本的所有实例。”嗯，我不认为这是现成的。Spring Cloud最酷的地方在于，所有这些服务，包括Eureka Server，都只是我们可以根据自己的需要破解的Spring应用程序。下面的代码公开了一个endpoint，该endpoint将实例设置为给定应用程序名称和版本的“停止服务”。只需将此控制器添加到Eureka服务器。它还没有准备好生产，只是一个想法。

现在，一旦Eureka停止这些实例的服务，Ribbon刷新其服务器列表，就可以安全地终止或路由这些实例。

发布到:

http://[eurekahost:port]/takeInstancesOutOfService?applicationName=FOOBAR&version=8675309

希望这有帮助？

import java.util.Collection;
import java.util.function.Predicate;
import java.util.stream.Collectors;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import com.netflix.appinfo.InstanceInfo;
import com.netflix.appinfo.InstanceInfo.InstanceStatus;
import com.netflix.discovery.shared.Application;
import com.netflix.eureka.EurekaServerContextHolder;
import com.netflix.eureka.registry.PeerAwareInstanceRegistry;

@RestController
public class EurekaInstanceStateController {

    @RequestMapping(value="/instancesQuery", method=RequestMethod.POST)
    public Collection<String> queryInstancesByMetaData(
            @RequestParam("applicationName") String applicationNameCriteria,
            @RequestParam("version") String versionCriteria)
    {
        return getRegistry().getSortedApplications()
                .stream()
                .filter(hasApplication(applicationNameCriteria))
                .flatMap(app -> app.getInstances().stream())
                .filter(hasVersion(versionCriteria))
                .map(info -> info.getAppName() + " - " + info.getId() + " - " + info.getStatus() + " - " + info.getMetadata().get("version"))
                .collect(Collectors.toList());
    }

    @RequestMapping(value="/takeInstancesOutOfService", method=RequestMethod.POST)
    public Collection<String> takeInstancesOutOfService(
            @RequestParam("applicationName") String applicationNameCriteria,
            @RequestParam("version") String versionCriteria)
    {
        return getRegistry().getSortedApplications()
                .stream()
                .filter(hasApplication(applicationNameCriteria))
                .flatMap(app -> app.getInstances().stream())
                .filter(hasVersion(versionCriteria))
                .map(instance -> updateInstanceStatus(instance, InstanceStatus.OUT_OF_SERVICE) )
                .collect(Collectors.toList());
    }

    /**
     * @param instance
     * @return
     */
    private String updateInstanceStatus(InstanceInfo instance, InstanceStatus status)
    {
        boolean isSuccess = getRegistry().statusUpdate(instance.getAppName(), instance.getId(),
        status, String.valueOf(System.currentTimeMillis()),
        true);

        return (instance.getAppName() + " - " + instance.getId() + " result: " + isSuccess);
    }

    /**
     * Application Name Predicate
     * @param applicationNameCriteria
     * @return
     */
    private Predicate<Application> hasApplication(final String applicationNameCriteria)
    {
        return application -> applicationNameCriteria.toUpperCase().equals(application.getName());
    }

    /**
     * Instance Version Predicate.  Uses Eureka Instance Metadata value name "version".</br>
     * 
     * Set / Bake the instance metadata map to contain a version value.</br>  
     * e.g. eureka.instance.metadataMap.version=85839c2
     * 
     * @param versionCriteria
     * @return
     */
    private Predicate<InstanceInfo> hasVersion(final String versionCriteria)
    {
        return info -> versionCriteria.equals(info.getMetadata().get("version"));
    }

    private PeerAwareInstanceRegistry getRegistry() {
        return EurekaServerContextHolder.getInstance().getServerContext().getRegistry();
    }
}