virtualHost 不使用 application.yml springboot 和配置服务器在 RabbitMQ 服务器上创建
virtualHost Not Creating on RabbitMQ server using application.yml springboot and from config server
没有根据配置在 RabbitMQ 服务器上创建虚拟主机
我是否已确保 RabbitMQ 上的 VH aka 虚拟主机。
我是否缺少一些配置。
请在下面找到配置
application.yml
spring:
rabbitmq:
host: 127.0.0.1
virtual-host: /defaultVH
username: defaultUser
password: defaultPassword
cloud:
stream:
bindings:
saviyntSampleQueueA:
binder: rabbit-A
contentType: application/x-java-object
group: groupA
destination: saviyntSampleQueueA
saviyntSampleQueueB:
binder: rabbit-B
contentType: application/x-java-object
group: groupB
destination: saviyntSampleQueueB
binders:
rabbit-A:
defaultCandidate: false
inheritEnvironment: false
type: rabbit
environment:
spring:
rabbitmq:
host: 127.0.0.1
virtualHost: /vhA
username: userA
password: paswdA
port: 5672
connection-timeout: 10000
rabbit-B:
defaultCandidate: false
inheritEnvironment: false
type: rabbit
environment:
spring:
rabbitmq:
host: 127.0.0.1
virtualHost: /vhB
username: userB
password: paswdB
port: 5672
connection-timeout: 10000
bootstrap.yml
############################################
# default settings
############################################
spring:
main:
banner-mode: "off"
application:
name: demo-service
cloud:
config:
enabled: true #change this to use config-service
retry:
maxAttempts: 3
discovery:
enabled: false
fail-fast: true
override-system-properties: false
server:
port: 8080
添加了默认值 spring 启动添加了启用绑定
@EnableBinding({MessageChannels.class})
@SpringBootApplication
public class Configissue1124Application {
public static void main(String[] args) {
SpringApplication.run(Configissue1124Application.class, args);
}
}
现在简单直接的按摩频道来发送按摩
interface MessageChannels {
@Input("saviyntSampleQueueA")
SubscribableChannel queueA();
@Input("saviyntSampleQueueB")
SubscribableChannel queueB();
}
当我 运行 启动应用程序时,它不会在系统上创建任何虚拟主机。我尝试使用配置服务器购买提供相同的配置但仍然没有运气
你能找到是否缺少某些东西吗?
提前致谢
AMQP 协议(或 RabbitMQ REST API)不提供从客户端提供虚拟主机的机制。
必须在服务器上手动配置虚拟主机。
没有根据配置在 RabbitMQ 服务器上创建虚拟主机 我是否已确保 RabbitMQ 上的 VH aka 虚拟主机。 我是否缺少一些配置。 请在下面找到配置
application.yml
spring:
rabbitmq:
host: 127.0.0.1
virtual-host: /defaultVH
username: defaultUser
password: defaultPassword
cloud:
stream:
bindings:
saviyntSampleQueueA:
binder: rabbit-A
contentType: application/x-java-object
group: groupA
destination: saviyntSampleQueueA
saviyntSampleQueueB:
binder: rabbit-B
contentType: application/x-java-object
group: groupB
destination: saviyntSampleQueueB
binders:
rabbit-A:
defaultCandidate: false
inheritEnvironment: false
type: rabbit
environment:
spring:
rabbitmq:
host: 127.0.0.1
virtualHost: /vhA
username: userA
password: paswdA
port: 5672
connection-timeout: 10000
rabbit-B:
defaultCandidate: false
inheritEnvironment: false
type: rabbit
environment:
spring:
rabbitmq:
host: 127.0.0.1
virtualHost: /vhB
username: userB
password: paswdB
port: 5672
connection-timeout: 10000
bootstrap.yml
############################################
# default settings
############################################
spring:
main:
banner-mode: "off"
application:
name: demo-service
cloud:
config:
enabled: true #change this to use config-service
retry:
maxAttempts: 3
discovery:
enabled: false
fail-fast: true
override-system-properties: false
server:
port: 8080
添加了默认值 spring 启动添加了启用绑定
@EnableBinding({MessageChannels.class})
@SpringBootApplication
public class Configissue1124Application {
public static void main(String[] args) {
SpringApplication.run(Configissue1124Application.class, args);
}
}
现在简单直接的按摩频道来发送按摩
interface MessageChannels {
@Input("saviyntSampleQueueA")
SubscribableChannel queueA();
@Input("saviyntSampleQueueB")
SubscribableChannel queueB();
}
当我 运行 启动应用程序时,它不会在系统上创建任何虚拟主机。我尝试使用配置服务器购买提供相同的配置但仍然没有运气 你能找到是否缺少某些东西吗?
提前致谢
AMQP 协议(或 RabbitMQ REST API)不提供从客户端提供虚拟主机的机制。
必须在服务器上手动配置虚拟主机。