小编tsa*_*txt的帖子

我正在尝试使用Spring BootwithKafka和ZooKeeperwithDocker：

docker-compose.yml:

version: \'2\'\n\nservices:\n\nzookeeper:\n image: wurstmeister/zookeeper\n restart: always\n ports:\n   - "2181:2181"\n\nkafka:\n image: wurstmeister/kafka\n restart: always\n ports:\n   - "9092:9092"\n environment:\n   KAFKA_ADVERTISED_HOST_NAME: localhost\n   KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181\n

docker ps输出：

CONTAINER ID        IMAGE                    COMMAND                            CREATED             STATUS              PORTS                                                        NAMES\n980e6b09f4e3        wurstmeister/kafka       "start-kafka.sh"         29 minutes ago      Up 29 minutes       0.0.0.0:9092->9092/tcp                               samplespringkafkaproducerconsumermaster_kafka_1\n64519d4808aa        wurstmeister/zookeeper   "/bin/sh -c \'/usr/sb\xe2\x80\xa6"   2 hours ago         Up 29 minutes       22/tcp, 2888/tcp, 3888/tcp, 0.0.0.0:2181->2181/tcp   samplespringkafkaproducerconsumermaster_zookeeper_1\n

docker-compose up输出日志：

kafka_1      | [2018-01-12 …

我正在尝试将微服务Spring Boot与一起使用Kafka，但是我的Spring Boot容器无法连接到该Kafka容器。

docker-compose.yml：

version: '3'

services:

  zookeeper:
    image: wurstmeister/zookeeper
    container_name: zookeeper
    restart: always
    ports:
      - 2181:2181

  kafka:
    image: wurstmeister/kafka
    container_name: kafka
    restart: always
    ports:
      - 9092:9092
    depends_on:
      - zookeeper
    links:
      - zookeeper:zookeeper
    environment:
      KAFKA_ADVERTISED_HOST_NAME: localhost
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181

  consumer:
    image: consumer
    container_name: consumer
    depends_on:
      - kafka
    restart: always
    ports:
      - 8084:8080
    depends_on:
      - kafka
    links:
      - kafka:kafka

  producer:
    image: producer
    container_name: producer
    depends_on:
      - kafka
    restart: always
    ports:
      - 8085:8080
    depends_on: …

Spring-Data-JPA中的方法 CrudRepository

 <S extends T> Iterable<S> saveAll(Iterable<S> entities)

以相同的顺序返回列表？

当一个变成第二个时如何模拟2个豆子？

public class A {
...
}

public class B {
private A a;
}

我试过了：

@MockBean 
private A a;

@InjectMocks 
private B b;

@Before
public void executedBeforeEach() {
MockitoAnnotations.initMocks(this);
}

但有例外：

org.mockito.exceptions.base.MockitoException: 
Cannot instantiate @InjectMocks field named 'B'.
You haven't provided the instance at field declaration so I tried to     construct the instance.
However, I failed because: the type 'B' is an interface.

春季版：

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.8.RELEASE</version>
    <relativePath/>
</parent>

测试依赖项：

<dependencies>
...
<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
    </dependency>
 </dependencies> …

我试图用一个mapstruct，我需要映射Entity与子Entity列表，我有关系，oneToMany而且manyToOne，我需要在这两种情况下的映射：

@Data
@Entity
public class EmailEntity {

private int id;  

... // some fields

@ManyToOne
private DeliveredEmailInfoEntity deliveredEmailInfo;

}

.

@Data
@Entity
public class DeliveredEmailInfoEntity {

private int id;

... // some fields  

@OneToMany
private List<EmailEntity> emails;

}

映射到：

@Data
public class EmailDTO {

private int id;  

... // some fields

private DeliveredEmailInfoDTO deliveredEmailInfo;

}

.

@Data
public class DeliveredEmailInfoDTO {

private int id;

... // some fields  

private List<EmailDTO> …

我正在尝试在 中的微服务之间rest发出请求，但出现错误。restTemplateSpring Bootdocker

docker-compose.yml：

  api:
    image: api-service
    container_name: api-service
    restart: always
    depends_on:
      - product
    ports:
      - 8081:8080
    links:
      - product:product
    environment:
      - SERVICE_PORT_PRODUCT=8083

  product:
    image: product-service
    container_name: product-service
    restart: always
    ports:
      - 8083:8080

Exception 日志：

ERROR 1 --- [nio-8080-exec-1] o.a.c.c.C.[.[.[/].[dispatcherServlet]    : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.web.client.ResourceAccessException: I/O error on POST request for "http://product:8083/api/products/": Connection refused (Connection refused); nested exception is java.net.ConnectException: …