spring-rabbitmq

0열

1답변

spring-stream은 "application/json"대신 "text/plain"content-type을 사용하여 메시지를 보냅니다.

페이로드에 json 객체가 포함되어 있으므로 content type application/json으로 응답을 생성하고 싶습니다. 하지만 ... (RabbitMQ 기준) 내 봄 스트림은 항상 아래 헤더 (페이로드가 정확하고 JSON 양식을 가지고)와 메시지를 생성하는 이유 알고하지 마십시오. = 캐릭터 셋 UTF-8, (view from rabbit ui)

0열

3답변

Spring Cloud 스프링 서비스 커넥터 (RabbitMQ 포함)

CloudFoundry에서 Rabbitmq 서비스를 연결하기 위해 스프링 클라우드 스프링 서비스 커넥터를 사용합니다. public class CloudConfig extends AbstractCloudConfig { @Bean public ConnectionFactory rabbitFactory() { return c

-1열

1답변

rabbit mq에서 매우 느림 읽음

나는 rabbitmq 대기열에서 읽어야 만하는 작업을 데이터 저장소에 씁니다. 현재 큐에서 메시지를 읽는 데 AmqpItemReader을 사용하고 있습니다. 읽은 데이터는 Json 형식이며 모든 내 ItemProcessor은 json을 Java 객체로 직렬화합니다. 단일 스레드 솔루션의 성능이 매우 낮습니다. 나는 초당 12ms의 속도로만 소비 할 수있다.

0열

1답변

사용 봄 클라우드 봄 서비스 RabbitMQ와 커넥터 및 시작 게시자 설정 기능

나는 sprin 클라우드 설정과 RabbitMQ를 연결합니다 @Bean public ConnectionFactory rabbitConnectionFactory() { Map<String, Object> properties = new HashMap<String, Object>(); properties.put("publisherConfirm

1열

1답변

STOMP를 통한 RabbitMQ 내구성 큐 손실 메시지

tomcat에 배포 된 스프링 응용 프로그램에 의해 노출되는 javascript/websockets를 사용하여 토끼 mq 브로커에 연결하는 웹 페이지가 있습니다. 메시지는 외부 응용 프로그램에서 초당 1 개씩 생성되며 웹 페이지에 렌더링됩니다. 자바 스크립트 구독은 내구성이 있습니다. 내가 겪고있어 문제는 네트워크 연결이 일정 기간 동안 자바 스크립트 클라

0열

1답변

RabbitMQ Exchange 및 대기열이 자동으로 생성되지 않음

rabbitmq 서버에 메시지를 푸시하는 새 스프링 애플리케이션을 만들었습니다. 내 rabbitMQConfig 자바 파일은 다음과 같다 : 여기 @Configuration public class RabbitMQConfig { private static final Logger LOGGER = LoggerFactory.getLogger(Rabbit

0열

1답변

토끼 리스너 Rabbitmq 노드가 다운되면 항상 소비자를 실행하거나 중지

사용할 수 RabbitMq 서버는 Rabbitmq Exchange를 일부 메시지를 생산 및 토끼와 QUEUENAME에 메시지 기지 Listener.but 큐 스피에는 메시지 항상 점점없는 경우 있음을 소모하고 때 <bean id="rabbitListenerContainerFactory" class="org.springframework.amqp.rabbit.

0열

1답변

서비스가 다시 시작되면 Rabbitmq에서 메시지를 알리지 않습니다.

제 시스템에서는 이벤트를 보내고 받기 위해 spring-cloud-stream과 RabbitMQ를 사용합니다. 내 토끼 메신저를 실행 서비스 대답 최대 및 서비스 B 다운 있어요. 서비스 A은 서비스 B으로 이벤트를 보냅니다. 그런 다음 내 서비스 B을 표시하고 이제는 Rabbit이 이벤트를 속일 것이라고 기대하지만 아무런 반응이 없습니다. 올바른 행동입니

0열

1답변

RabbitMQ와 Spring을 위해 동적으로 대기열과 독점 소비자/수신기를 등록하는 방법은 무엇입니까?

해결해야 할 다음과 같은 문제가 있습니다. RabbitMQ 메시징을 사용하여 간단한 지연된 다시 시도 메커니즘을 구현하려고합니다. 나는 메시지 전달의 지연을 가져 오는 기반 시설을 가지고있다. 런타임에 지연된 재시도 메커니즘을 활용하고자하는 관심있는 참가자가 많을 수 있습니다. 참석자는 2 개의 세부 정보와 메시지 만 제공하려고합니다. 1. T 초간의 지연

0열

1답변

오류 응용 프로그램 시작에 가상 호스트에서 어떤 큐 I이 구성 클래스로 구성 RabbitMQ가있는 봄 부팅 응용 프로그램을 시작하려고 해요

: @Configuration public class RabbitConfig implements RabbitListenerConfigurer { public static final String AMQP_EXCHANGE_NAME = "test-queue"; @Bean public Exchange accessExchange()