小编Bar*_*ona的帖子

在AngularJS中,我看到有时我们使用$state.transitionTo(),有时我们使用$state.go().任何人都可以告诉我他们的差异,以及何时应该使用另一个？

我发现了一个关于 peek 方法的 Java 8 Stream API 的测验，如下所示

Arrays.asList("Fred", "Jim", "Sheila")
      .stream()
      .peek(System.out::println)
      .allMatch(s -> s.startsWith("F"));

输出是

Fred
Jim

我很困惑这个流是如何工作的？我的预期结果应该是

Fred
Jim
Sheila

peek() 方法是一个中间操作，它处理 Stream 中的每个元素。谁能给我解释一下。

在事件驱动的微服务架构中处理前端和后端之间的通信时，我很担心：

用例：用户创建新产品然后他去产品列表检查。流程如下

我的问题是在这种情况下 UI 如何处理产品列表？新产品可能不存在，因为读取端尚未处理新产品事件。

我正在创建一个新的java web项目.这个Web应用程序将有许多模块,如核心/公共,业务服务,存储库,安全性,集成,ldap,用户管理......我想知道是否应该将每个模块分成每个maven项目(jar文件)或创建项目包括所有模块的所有java包到单个maven项目中.

Structure of Multi modules maven project

   mycompany-core
   mycompany-repository
   mycompany-api
   mycompany-usermanagement
   mycompany-business
   mycompany-web

Structure of Single module project:

   mycompany-web
       |___ src
             |____ main
                    |____ java
                            |____ com.mycompany.core
                            |____ com.mycompany.repository
                            |____ com.mycompany.business
                            |____ com.mycompany.controller

什么时候应该应用多模块或单模块项目>请给我一些建议.

我将为我的应用程序应用微服务架构.微服务之间的内部通信将通过使用Akka来实现.但我不知道如何使所有微服务知道并相互注册.我有一些设计Service Registry和Discovery的选项:

1)使用Zookeeper作为中心化服务来保存所有微服务(节点)的所有元数据,并让他们访问这些元数据进行通信.每个节点的元数据包含Akka路径(地址)信息,以便让其他节点进行通信.

2)将所有微服务(Akka Nodes)加入Akka集群,每个节点将保持彼此的引用以进行通信.Akka Cluster支持八卦协议,它将让群集中的所有节点一起识别.

有人可以给我一些建议吗？如何在Akka之上有效地设计服务发现和服务注册表？这有什么选择吗？

我有一个基于Spring的应用程序,它有一个后台轮​​询服务在一个单独的线程中运行,以更新database(EmployeeStatusPollService)中的数据状态.我使用JPA(Hibernate供应商)作为存储库.我在两个解决方案中实现了这项服务,但只有一个解决方案有效 以下是两种解决方案.

解决方案1:checkAndUpdateStatus其他服务类和poll服务中的事务方法调用它

@Service
public class EmployeeStatusPollService implements Runnable {

  @Inject 
  private EmployeeService employeeService;

  private static final int DEFAULT_PAGE_SIZE = 300;
  private boolean flag = true;

  public EmployeeStatusPollService() {
  }

  @PostConstruct
  public void start() {
    SimpleAsyncTaskExecutor executor = new SimpleAsyncTaskExecutor();
    executor.setConcurrencyLimit(SimpleAsyncTaskExecutor.NO_CONCURRENCY);
    executor.execute(this);
  }

  public void run() { 
    while(flag) {
      try {
        int pagenum = 1;
        List<Employee> items = null;

        do {        
          items = employeeService.checkAndUpdateStatus(pagenum, DEFAULT_PAGE_SIZE);
        } while(items != null && items.size() == DEFAULT_PAGE_SIZE);      
      } catch(Exception ex) …

我将为我的Datawarehouse应用程序应用微服务.应用中有4个主要的微服务:

1)数据服务:将外部数据源导入/导出到DWH,并从DWH查询数据.

2)分析服务:用于UI上的图表可视化

3)机器学习:用于推荐系统

4)报告:报告生成

图如下:

每个服务都有自己的DB,它们通过TCP和Thift序列化直接相互通信.这里的问题是数据服务遭受来自其他服务的高负载,并且可以成为应用程序的SPOF.DWH中的数据也很大(可能高达数百个记录).在这种情况下如何避免数据服务的瓶颈？或者我如何定义一个适当的有界上下文来避免瓶颈？