错误：将ESTABILREFUSED 8080 keycloak与 Spring Boot 连接

yhxst69z  于 2024-01-06  发布在  Spring
关注(0)|答案(1)|浏览(291)

端口8080与端口8180重叠
这是我第一次使用keycloack、spring Boot 和docker启动一个应用程序。设置和使用keycloack本身并没有引起任何问题。Docker运行得很顺利。但是当我请求从postman到spring方法时，我得到一个错误错误错误：connect EASPING REFUSED 127.0.0.1:8080
docker-compose.yml

  1. version: '3.9'
  3. services:
  4.   keycloak:
  5.     container_name: keycloak-auth
  6.     image: quay.io/keycloak/keycloak:22.0.1
  8.     command:
  9.       - "start-dev"
  10.     ports:
  11.       - "8180:8080"
  12.     networks:
  13.       - keycloak
  14.     environment:
  15.       KEYCLOAK_ADMIN: admin
  16.       KEYCLOAK_ADMIN_PASSWORD: password
  17.       KC_DB: postgres
  18.       KC_DB_URL_HOST: keycloak-db
  19.       KC_DB_URL_DATABASE: keycloak
  20.       KC_DB_USERNAME: keycloak
  21.       KC_DB_PASSWORD: password
  22.       KC_HEALTH_ENABLED: true
  23.     depends_on:
  24.       - keycloak-db
  25.   keycloak-db:
  26.     image: postgres:14-alpine
  27.     container_name: keycloak-db
  28.     ports:
  29.       - "5433:5432"
  30.     volumes:
  31.       - postgres_data_keycloak:/var/lib/postgresql/data
  32.     environment:
  33.       POSTGRES_DB: keycloak
  34.       POSTGRES_USER: keycloak
  35.       POSTGRES_PASSWORD: password
  36.     networks: [ keycloak ]
  37.     healthcheck:
  38.       test: [ "CMD", "pg_isready", "-q", "-d", "postgres", "-U" ]
  39.       timeout: 45s
  40.       interval: 10s
  41.       retries: 10
  43.   activemq:
  44.     image: webcenter/activemq:latest
  45.     ports:
  46.       # mqtt
  47.       - "1883:1883"
  48.       # amqp
  49.       - "5672:5672"
  50.       # ui
  51.       - "8161:8161"
  52.       # stomp
  53.       - "61613:61613"
  54.       # ws
  55.       - "61614:61614"
  56.       # jms
  57.       - "61616:61616"
  58.     networks: [ activemq ]
  59.     volumes: [ "activemq-data:/opt/activemq/conf", "activemq-data:/data/activemq", "activemq-data:/var/log/activemq" ]
  60.     environment:
  61.       ACTIVEMQ_REMOVE_DEFAULT_ACCOUNT: "true"
  62.       ACTIVEMQ_ADMIN_LOGIN: admin
  63.       ACTIVEMQ_ADMIN_PASSWORD: password
  64.       ACTIVEMQ_WRITE_LOGIN: write
  65.       ACTIVEMQ_WRITE_PASSWORD: password
  66.       ACTIVEMQ_READ_LOGIN: read
  67.       ACTIVEMQ_READ_PASSWORD: password
  68.       ACTIVEMQ_JMX_LOGIN: jmx
  69.       ACTIVEMQ_JMX_PASSWORD: password
  71.       ACTIVEMQ_STATIC_TOPICS: static-topic-1;static-topic-2;autoTopic
  72.       ACTIVEMQ_STATIC_QUEUES: static-queue-1;static-queue-2
  73.       ACTIVEMQ_ENABLED_SCHEDULER: "true"
  74.       ACTIVEMQ_MIN_MEMORY: 512
  75.       ACTIVEMQ_MAX_MEMORY: 2048
  77. networks:
  78.   keycloak:
  79.     name: keycloak
  80.     driver: bridge
  81.   activemq: { }
  83. volumes:
  84.   postgres_data_keycloak:
  85.     driver: local
  86.   activemq-data:
  87.     driver: local

字符串
安全配置

  1. @Configuration
  2. @EnableWebSecurity
  3. @EnableMethodSecurity
  4. class SecurityConfig {
  6.     @Bean
  7.     public SecurityFilterChain securityFilterChain(HttpSecurity httpSecurity) throws Exception {
  9.         httpSecurity
  10.                 //TODO: security without @PreAuthorize
  11.                 /* .authorizeHttpRequests(registry -> registry
  12.                         .requestMatchers(HttpMethod.GET, "/api/**").hasRole("USER")
  13.                         .requestMatchers(HttpMethod.POST, "/api/**").hasRole("PERSON")
  14.                         .anyRequest().authenticated()
  15.                 )*/
  16.                 .oauth2ResourceServer(oauth2Configurer -> oauth2Configurer
  17.                         .jwt(jwtConfigurer -> jwtConfigurer
  18.                                 .jwtAuthenticationConverter(jwt -> {
  19.                                     Map<String, Collection<String>> realmAccess = jwt.getClaim("realm_access");
  20.                                     Collection<String> roles = realmAccess.get("roles");
  22.                                     var grantedAuthorities = roles.stream()
  23.                                             .map(role -> new SimpleGrantedAuthority("ROLE_" + role))
  24.                                             .collect(Collectors.toList());
  26.                                     return new JwtAuthenticationToken(jwt, grantedAuthorities);
  27.                                 })));
  28.         return httpSecurity.build();
  29.     }
  30. }

型
控制器

  1. @RestController
  2. @RequestMapping(value = "/api", produces = MediaType.APPLICATION_JSON_VALUE)
  3. @RequiredArgsConstructor
  4. @Slf4j
  5. public class AutomobileRestController implements AutomobileResource, AutomobileOpenApi, JMSPublisher {
  7.     private final AutomobileRepository repository;
  8.     private final JmsTemplate jmsTemplate;
  10.     public static double getTiming(Instant start, Instant end) {
  11.         return Duration.between(start, end).toMillis();
  12.     }
  14.     @Transactional
  15.     @PostConstruct
  16.     public void init() {
  17.         repository.save(new Automobile(1L, "Ford", "Green", LocalDateTime.now(), LocalDateTime.now(), true, false));
  18.     }
  20.     @PostMapping("/automobiles")
  21.     @ResponseStatus(HttpStatus.CREATED)
  22.     @PreAuthorize("hasRole('ADMIN')")
  23.     //@RolesAllowed("ADMIN")
  24.     public Automobile saveAutomobile(@Valid @RequestBody Automobile automobile) {
  25.         log.info("saveAutomobile() - start: automobile = {}", automobile);
  26.         Automobile savedAutomobile = repository.save(automobile);
  27.         log.info("saveAutomobile() - end: savedAutomobile = {}", savedAutomobile.getId());
  28.         return savedAutomobile;
  29.     }
  31.     @GetMapping("/automobiles")
  32.     @ResponseStatus(HttpStatus.OK)
  33.     @PreAuthorize("hasRole('USER')")
  34.     public Collection<Automobile> getAllAutomobiles() {
  35.         log.info("getAllAutomobiles() - start");
  36.         Collection<Automobile> collection = repository.findAll();
  37.         log.info("getAllAutomobiles() - end");
  38.         return collection;
  39.     }
  41.     @GetMapping("/automobiles/{id}")
  42.     @ResponseStatus(HttpStatus.OK)
  43.     @PreAuthorize("hasRole('PERSON')")
  44.     public Automobile getAutomobileById(@PathVariable Long id) {
  45.         log.info("getAutomobileById() - start: id = {}", id);
  46.         Automobile receivedAutomobile = repository.findById(id)
  47.                 .orElseThrow(ThereIsNoSuchAutoException::new);
  48.         if (receivedAutomobile.getDeleted()) {
  49.             throw new AutoWasDeletedException();
  50.         }
  51.         log.info("getAutomobileById() - end: Automobile = {}", receivedAutomobile.getId());
  52.         return receivedAutomobile;
  53.     }
  55.     @Hidden
  56.     @GetMapping(value = "/automobiles", params = {"name"})
  57.     @ResponseStatus(HttpStatus.OK)
  58.     public Collection<Automobile> findAutomobileByName(@RequestParam(value = "name") String name) {
  59.         log.info("findAutomobileByName() - start: name = {}", name);
  60.         Collection<Automobile> collection = repository.findByName(name);
  61.         log.info("findAutomobileByName() - end: collection = {}", collection);
  62.         return collection;
  63.     }
  65.     @PutMapping("/automobiles/{id}")
  66.     @ResponseStatus(HttpStatus.OK)
  67.     //@CachePut(value = "automobile", key = "#id")
  68.     public Automobile refreshAutomobile(@PathVariable Long id, @RequestBody Automobile automobile) {
  69.         log.info("refreshAutomobile() - start: id = {}, automobile = {}", id, automobile);
  70.         Automobile updatedAutomobile = repository.findById(id)
  71.                 .map(entity -> {
  72.                     entity.checkColor(automobile);
  73.                     entity.setName(automobile.getName());
  74.                     entity.setColor(automobile.getColor());
  75.                     entity.setUpdateDate(automobile.getUpdateDate());
  76.                     if (entity.getDeleted()) {
  77.                         throw new AutoWasDeletedException();
  78.                     }
  79.                     return repository.save(entity);
  80.                 })
  81.                 //.orElseThrow(() -> new EntityNotFoundException("Automobile not found with id = " + id));
  82.                 .orElseThrow(ThereIsNoSuchAutoException::new);
  83.         log.info("refreshAutomobile() - end: updatedAutomobile = {}", updatedAutomobile);
  84.         return updatedAutomobile;
  85.     }
  87.     @DeleteMapping("/automobiles/{id}")
  88.     @ResponseStatus(HttpStatus.NO_CONTENT)
  89.     @CacheEvict(value = "automobile", key = "#id")
  90.     public String removeAutomobileById(@PathVariable Long id) {
  91.         log.info("removeAutomobileById() - start: id = {}", id);
  92.         Automobile deletedAutomobile = repository.findById(id)
  93.                 .orElseThrow(ThereIsNoSuchAutoException::new);
  94.         deletedAutomobile.setDeleted(Boolean.TRUE);
  95.         repository.save(deletedAutomobile);
  96.         log.info("removeAutomobileById() - end: id = {}", id);
  97.         return "Deleted";
  98.     }
  100.     @Hidden
  101.     @DeleteMapping("/automobiles")
  102.     @ResponseStatus(HttpStatus.NO_CONTENT)
  103.     public void removeAllAutomobiles() {
  104.         log.info("removeAllAutomobiles() - start");
  105.         repository.deleteAll();
  106.         log.info("removeAllAutomobiles() - end");
  107.     }
  109.     @GetMapping(value = "/automobiles", params = {"color"})
  110.     @ResponseStatus(HttpStatus.OK)
  111.     public Collection<Automobile> findAutomobileByColor(
  112.             @Parameter(description = "Name of the Automobile to be obtained. Cannot be empty.", required = true)
  113.             @RequestParam(value = "color") String color) {
  114.         Instant start = Instant.now();
  115.         log.info("findAutomobileByColor() - start: time = {}", start);
  116.         log.info("findAutomobileByColor() - start: color = {}", color);
  117.         Collection<Automobile> collection = repository.findByColor(color);
  118.         Instant end = Instant.now();
  119.         log.info("findAutomobileByColor() - end: milliseconds = {}", getTiming(start, end));
  120.         log.info("findAutomobileByColor() - end: collection = {}", collection);
  121.         return collection;
  122.     }
  124.     @GetMapping(value = "/automobiles", params = {"name", "color"})
  125.     @ResponseStatus(HttpStatus.OK)
  126.     public Collection<Automobile> findAutomobileByNameAndColor(
  127.             @Parameter(description = "Name of the Automobile to be obtained. Cannot be empty.", required = true)
  128.             @RequestParam(value = "name") String name, @RequestParam(value = "color") String color) {
  129.         log.info("findAutomobileByNameAndColor() - start: name = {}, color = {}", name, color);
  130.         Collection<Automobile> collection = repository.findByNameAndColor(name, color);
  131.         log.info("findAutomobileByNameAndColor() - end: collection = {}", collection);
  132.         return collection;
  133.     }
  135.     @GetMapping(value = "/automobiles", params = {"colorStartsWith"})
  136.     @ResponseStatus(HttpStatus.OK)
  137.     public Collection<Automobile> findAutomobileByColorStartsWith(
  138.             @RequestParam(value = "colorStartsWith") String colorStartsWith,
  139.             @RequestParam(value = "page") int page,
  140.             @RequestParam(value = "size") int size) {
  141.         log.info("findAutomobileByColorStartsWith() - start: color = {}", colorStartsWith);
  142.         Collection<Automobile> collection = repository
  143.                 .findByColorStartsWith(colorStartsWith, PageRequest.of(page, size, Sort.by("color")));
  144.         log.info("findAutomobileByColorStartsWith() - end: collection = {}", collection);
  145.         return collection;
  146.     }
  148.     @GetMapping("/automobiles-names")
  149.     @ResponseStatus(HttpStatus.OK)
  150.     public List<String> getAllAutomobilesByName() {
  151.         log.info("getAllAutomobilesByName() - start");
  152.         List<Automobile> collection = repository.findAll();
  153.         List<String> collectionName = collection.stream()
  154.                 .map(Automobile::getName)
  155.                 .sorted()
  156.                 .collect(Collectors.toList());
  157.         log.info("getAllAutomobilesByName() - end");
  158.         return collectionName;
  159.     }
  161.     @Override
  162.     @PostMapping("/message")
  163.     @ResponseStatus(HttpStatus.CREATED)
  164.     public ResponseEntity<Automobile> pushMessage(@RequestBody Automobile automobile) {
  165.         try {
  166.             Topic autoTopic = Objects.requireNonNull(jmsTemplate
  167.                     .getConnectionFactory()).createConnection().createSession().createTopic("AutoTopic");
  168.             Automobile savedAutomobile = repository.save(automobile);
  169.             log.info("\u001B[32m" + "Sending Automobile with id: " + savedAutomobile.getId() + "\u001B[0m");
  170.             jmsTemplate.convertAndSend(autoTopic, savedAutomobile);
  171.             return new ResponseEntity<>(savedAutomobile, HttpStatus.OK);
  172.         } catch (Exception exception) {
  173.             return new ResponseEntity<>(null, HttpStatus.INTERNAL_SERVER_ERROR);
  174.         }
  175.     }
  176. }

型
Application.yml

  1. spring:
  2.   application:
  3.     name: App
  4.   profiles:
  5.     active: development
  6.   datasource:
  7.     driver-class-name: org.postgresql.Driver
  8.     url: jdbc:postgresql://localhost:5432/automobiles
  9.     username: postgres
  10.     password: postgres
  11.   jpa:
  12.     hibernate:
  13.       ddl-auto: update 
  14.     show-sql: true
  15.     database: postgresql
  16.     database-platform: org.hibernate.dialect.PostgreSQLDialect
  17.   security:
  18.     oauth2:
  19.       resource-server:
  20.         jwt:
  21.           issuer-uri: http://localhost:8180/realms/automobile-realm
  22.   jms:
  23.     pub-sub-domain: true
  24.   activemq:
  25.     broker-url: tcp://localhost:61616
  26. server:
  27.   port: 8080  
  28.   servlet:
  29.     context-path: /demo
  30. logging:
  31.   pattern:
  32.     console: "%d %-5level %logger : %msg%n"
  33.   level:
  34.     org.springframework: info
  35.     org.springframework.security: debug
  36.     org.springframework.security.oauth2: debug
  37. springdoc:
  38.   swagger-ui:
  39.     path: /swagger-ui.html 
  40.   api-docs:
  41.     path: /v3/api-docs.yaml
  42. management:
  43.   endpoints:
  44.     web:
  45.       exposure:
  46.         include: "*"

型
当我发出请求时，我得到一个错误：
x1c 0d1x的数据
在keycloak本身中，以下端口设置

我检查了端口在请求过程中不是忙碌的，keycloak在端口8180上工作，也许我错过了一些设置？
Dockerfile

  1. FROM openjdk:17
  2. ADD /target/spring-boot-keycloak-docker-postgres.jar spring-boot-keycloak-docker-postgres.jar
  3. ENTRYPOINT ["java", "-jar", "spring-boot-keycloak-docker-postgres.jar"]

型
docker-compose


的
logger docker-compose

spring-boot

1条答案

按热度按时间
2ekbmq32

2ekbmq321#

问题是，你的Spring Boot 应用程序不是通过你的docker-compose文件启动的。这个文件只是启动keycloak，它是DB和活动mq服务。
您应该将Sping Boot 应用打包为Docker镜像（https://spring.io/guides/topicals/spring-boot-docker/），并将其用作Docker compose文件中的另一个服务。

赞(0）分享  回复(0）举报  2024-01-06
我来回答

相关问题

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新问答

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com