3回答
在阅读Spring框架的文档时，我无意中发现了工厂方法中传递Bean依赖项的两种不同风格。第一个是这样的(直接使用依赖项的工厂方法)：
@Configuration
public class MessagingConfiguration {
@Bean
public ConnectionFactory connectionFactory() {
CachingConnectionFactory connectionFactory = new CachingConnectionFactory("localhost");
conne
浏览 9提问于2016-09-29得票数 5
回答已采纳
我使用的是Spring Boot。我正在尝试通过Spring Boot删除不使用Spring AMQP (RabbitMQ)的通道。但不知道如何实现它。任何帮助都是值得欣赏的。
ConnectionFactory声明：
public ConnectionFactory connectionFactory() {
final CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
connectionFactory.setUsername(userName);
浏览 49提问于2020-11-15得票数 0
2回答
java的本机rabbitmq客户端允许在连接设置上设置心跳，例如：
import com.rabbitmq.client.ConnectionFactory;
...
ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setAutomaticRecoveryEnabled(true);
connectionFactory.setHost("some://host");
connectionFactory.setCo
浏览 4提问于2015-11-10得票数 16
2回答
我尝试从Camel组件发送持久的消息到RabbitMQ。虽然默认选项为true，但我显式地设置了此选项：
.to(ExchangePattern.InOnly, "rabbitmq:demoExchange?queue=demoQueue" +
"&guaranteedDeliveries=true" +
"&mandatory=true" +
"&autoDelete=false" +
"&durable=true")
浏览 0提问于2019-09-05得票数 0
回答已采纳
我使用int:出站网关在兔子中创建消息。消息已发布，但我的流在ReplyRequiredException setPublisherReturns和setPublisherConfirms中停止设置在CachingConnectionFactory上。
当我设置requires回复'false‘时，线程被冻结，不再继续
代码：
<rabbit:template id="amqpTemplateCore" connection-factory="connectionFactoryCore" />
<bean id=&#
浏览 0提问于2016-08-31得票数 1
回答已采纳
这是我们用来创建/附加到队列的URL : tcp://localhost:61616?jms.prefetchPolicy.queuePrefetch=1
这会将queuePrefetch默认为1000：
IConnectionFactory connectionFactory = new ConnectionFactory(queueServer);
connectionFactory = new SingleConnectionFactory(connectionFactory)
{
ReconnectOnException = true
};
如果我们使用以下代码，它将适当地设置
浏览 2提问于2015-02-04得票数 1
回答已采纳
1回答
RabbitMQ慢接收速度
、、、、
我需要创建应用程序，它应该接收数据生产者的数据并对其进行处理。我选择RabbitMQ作为消息代理。我的测试结果并不是最好的：
发送- 100毫升；
生产- 100毫微克/秒；
消耗-6毫微克/秒；
为了解决这个问题，我设置了listenerContainer.setAcknowledgeMode(AcknowledgeMode.NONE);，但是对于某些队列，我需要确认。而且我不能使用工作人员并行地做这件事，因为消息的顺序对于数据处理很重要。
是否有可能提高接收的速度，承认？
制片人：
@Bean
Queue queue() {
return new Queue(queueName,
浏览 5提问于2017-11-02得票数 1
1回答
每当我在第一次接收消息时向队列发送消息时，没有任何问题，但是当我删除第二个文件时，消息处于“挂起”状态，即线程休眠时间(2分钟)。为了测试在ActiveMQ中工作的并发性，我添加了名为ThreadService的bean。
我在JMSConfig.java中有如下代码
@Bean
public ActiveMQConnectionFactory connectionFactory() {
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
connectionFactory
浏览 0提问于2019-09-16得票数 2
回答已采纳
我的hornetq在独立模式下运行。我需要使用注释的connectionfactory对象。
没有注解，我的代码就像这样。
public static void main(String args[]) {
Connection connection = null;
InitialContext initialContext = null;
ConnectionFactory connectionFactory = null;
Hashtable<String, String> env = new Hashta
浏览 0提问于2012-08-29得票数 0
当我尝试将.newConnection()发送到rabbitMQ服务器时，我会得到如下错误：
com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:126) at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:122) at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:373) at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQ
浏览 1提问于2018-08-02得票数 0
我有这样的配置，可以连接到compose.io rabbitmq服务。
package com.gandalf.configuration;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.cont
浏览 4提问于2017-12-23得票数 0
回答已采纳
1回答
我已经在spring 4中创建了下面的bean。在下面的配置文件中，当前声明的主机和其他变量是静态的。但是想要从数据库中动态获取它。无法找到如何获得它的方法。
请建议从数据库中获取它的方法。
@Configuration
public class RabbitMqConfiguration {
public static final String HOST = "localhost";
public static final String USERNAME = "test";
public static final String PAS
浏览 1提问于2018-08-16得票数 0
在我的项目中，我添加了两个不同的JmsListener，但是当我在ActiveMQ面板中运行项目时，只有其中一个主题有使用者！
那么，我应该为每个jmsListenerContainerFactory添加单独的JmsListener配置吗？
@JmsListener(destination = "foo1")
public void foo1(final Message jsonMessage) throws JMSException {
...
}
@JmsListener(destination = "foo2")
public void foo1
浏览 1提问于2018-02-03得票数 15
回答已采纳
1回答
我有下面的mq配置类，通过它我可以在接收队列中接收消息，但是当使用JmsTemplate bean时，我的消息不会发送到队列。我没有得到任何JmsException或任何异常，并且send()似乎成功了。它是一段XML字符串，我将其作为有效负载发送，如下所示：
jmsTemplate.send(session -> session.createTextMessage(payload));
@EnableJms
@Configuration
public class MessageQueueConfiguration {
@Bean(name = "test-factor
浏览 8提问于2019-11-07得票数 0
我很难理解下面的JMS示例中的JNDI部分。
public static void main(String[] args) {
try {
// Gets the JNDI context
Context jndiContext = new InitialContext();
// Looks up the administered objects
ConnectionFactory connectionFactory = (ConnectionFactory)
jndiContext.lo
浏览 1提问于2014-04-13得票数 9
回答已采纳
我刚刚开始使用rabbitmq，目前我正在做rabbitmq网站上的教程。我使用本地机器作为服务器，完成了hello world教程。现在，我想连接到另一台计算机上的远程服务器。我的问题是，我需要使用什么主机名来连接到此服务器。是安装rabbitmq服务器的机器的ip地址吗？
RabbitMQ.Client.ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.HostName = "XXX.X.X.X";
浏览 1提问于2014-11-06得票数 4
2回答
我通过Postgres JDBC驱动程序使用Java1.7和Postgres。数据库连接将从Web服务使用。在测试中，我得到了以下错误：
FATAL: connection limit exceeded for non-superusers
我将我的连接设为静态，并且只创建一次，从而解决了这个错误。我的问题是，静态连接安全吗？这是正确的方法吗？
我通过一个类似于下面这样的ConnectionFactory使用连接：
public class ConnectionFactory
{
String driverClassName = "org.postgresql.Driver&#
浏览 0提问于2013-03-04得票数 1
回答已采纳
1回答
我在spring-boot中使用了rabbitmq，下面是我的使用者配置：
@Bean(value = "distributionMqConnectionFactory")
public ConnectionFactory distributionMqConnectionFactory(){
CachingConnectionFactory connectionFactory=new CachingConnectionFactory();
connectionFactory.setAddresses(distributionMqServerAddress);
浏览 0提问于2018-03-17得票数 0
回答已采纳
由于某些原因，即使我在Spring AMQP队列配置中指定了该设置，我的队列也没有创建为持久队列：
@Bean
Queue queue() {
//durable queue - true
return new Queue(queueName, true);
}
我正在使用Spring AMQP连接到RabbitMQ并在Direct Exchange上监听该队列。
@Bean
DirectExchange exchange() {
return new DirectExchange(exchangeName);
}
@Bean
Binding binding(Queu
浏览 0提问于2016-01-22得票数 0
1回答
我正在使用spring开发RabbitMQ。
我有两个不同的虚拟主机，一个叫做d和p。
在d代码中，它有@注释。
在p代码中，我使用QueueBuilder自动创建队列。在启动spring应用程序时，我注意到newQueue是在d虚拟主机整数中创建的。如何使newQueue (自动创建队列)在p虚拟主机中创建？
下面是d配置
package com.example.config;
import lombok.Data;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
imp
浏览 37提问于2022-08-26得票数 0
为了从队列中接收消息，我很难获得与RabbitMQ集成的Spring 3应用程序(我不需要发送消息)。
挑战的一部分是现在与Spring相关的大部分文档。是有用的，但是在我的例子中，遵循这些步骤似乎不起作用。例如，指南包括以下案文：
消息侦听器容器和接收方bean是侦听消息所需的全部。
因此，我使用以下代码设置了侦听器容器和接收方bean。
设置消息处理程序
@Component
public class CustomMessageHandler {
public void handleMessage(String text) {
System.out.pri
浏览 1提问于2019-10-31得票数 0
2回答
目前，我正在开发一个必须使用连接工厂的应用程序。当我直接在全局级别上按设置的名称查找连接工厂时，一切正常，但为了实现解耦，我希望在我的应用程序中定义一个资源引用并查找该名称。因此，我在我的application.xml中创建了以下条目：
<resource-ref>
<res-ref-name>jms/connectionFactory</res-ref-name>
<res-type>javax.jms.ConnectionFactory</res-type>
<res-auth>Containe
浏览 1提问于2017-06-02得票数 1
回答已采纳
我正在尝试模拟RabbitMQ ConnectionFactory对象，以返回模拟的连接，使用scalatest和mockito。下面是我正在使用的示例测试：
class RabbitMQMockTest extends FunSuite with MockitoSugar {
test("RabbitMQ ConnectionFactory is correctly mocked") {
def connectionFactory = mock[ConnectionFactory]
def connection = mock[Conne
浏览 2提问于2011-12-29得票数 1
回答已采纳
我正在尝试设置一个RabbitMQ服务器( 3.7.4版本，通过macOS 10.13.4上的自制版本安装)，以便我的同事可以通过内部网络使用它。我们使用的是官方Java (com.rabbitmq:amqp-client:5.2.0)。不幸的是，他们只得到一个带有消息ConnectException的Connection refused。
java.net.ConnectException: Connection refused (Connection refused)
at java.net.PlainSocketImpl.socketConnect(Native Method)
浏览 1提问于2018-05-04得票数 2
回答已采纳
1回答
RabbitMQ失败连接
、、、、
我需要帮助，我的应用程序(客户端)连接到RabbitMQ服务器，当服务器关闭时，我的应用程序无法启动.
侦听器无法创建，应用程序启动失败。或者当虚拟主机没有队列时，我的应用程序也不能启动
所以我的问题
( 1)如何在配置中处理异常(如果RabbitMQ服务器有问题，我需要应用程序启动)
2)我的配置中有什么看起来很糟糕，需要重构
我使用
春季4.2.9
org.springframework.amqp 2.5.
Java 8
我的2节课
1) Beans RabbitMq的Config
2)侦听器注释
@EnableRabbit
@Configuration
浏览 0提问于2018-08-09得票数 0
我有一个应用程序(类似于Microservice)，它应该发送和接收来自其他应用程序(Microservices)的消息。该应用程序有多个发布者，每个发布服务器都发布到特定队列，以及多个订阅者类，每个订阅者只订阅一个队列。不幸的是，我的订阅服务器类正在使用与我发布的消息相同的消息。我该怎么做呢？
下面是我的代码: a) Publisher 1-没有侦听器方法，因为它只发布到my.queues.queue1
@Configuration
public class RabbitQueue1Publisher{
private static final String QUEUE_NAME =
浏览 0提问于2018-08-16得票数 0
1回答
我有两种不同的微服务，通过兔子进行交流。第一个微服务具有发布者的逻辑，我被要求创建使用者来使用消息ih队列，所有这些都在一个新的微服务中。
到目前为止，我所做的是这样的消费者的服务类：
@Service
public class RabbitMQService {
private final Logger logger = LoggerFactory.getLogger(RabbitMQService.class);
@RabbitListener(queues = "${peopleevents.queue}")
public void recei
浏览 4提问于2022-06-30得票数 0
我在这里不知所措，所以我向集体知识伸出援手，希望能出现奇迹。
我已经使用默认设置在Linux机器上安装了RabbitMQ。
当我使用这段代码(以及默认的RabbitMQ安装配置)时，一切都很正常。
var connectionFactory = new ConnectionFactory();
connectionFactory.HostName = "192.168.0.12";
IConnection connection = connectionFactory.CreateConnection();
但是当我将一个用户添加到RabbitMQ并尝试使用以下代码时(用户名和密
浏览 0提问于2011-02-14得票数 30
回答已采纳
1回答
我的应用程序当前使用的是IBM MQ，并且已经设置了队列配置，并且可以很好地与JMS配合使用。例如：
@EnableJms
@Configuration
public class IBMQueueConfig {
@Bean("defaultContainer")
public JmsListenerContainerFactory containerFactory(final ConnectionFactory connectionFactory,
浏览 53提问于2019-11-27得票数 1
回答已采纳
我正在用Spring实现测试请求/响应模式，但我无法使它工作.
我配置了以下工件：
带有问候队列的test_exchange。路由键=问候
带有回复队列的reply_exchange。路由密钥=应答
@Bean
public ConnectionFactory connectionFactory() {
CachingConnectionFactory connectionFactory =
new CachingConnectionFactory("....IP of broker...");
connectionFactory.se
浏览 5提问于2016-05-11得票数 0
回答已采纳
我们有一个需要与多实例QueueManager通信的应用程序.这两个实例都运行在默认端口上，并且具有唯一的地址。
serverA.internal.company.address
serverB.internal.company.address
我们使用以下代码来建立ConnectionFactory：
MQQueueConnectionFactory connectionFactory = new MQQueueConnectionFactory();
connectionFactory.setTransportType(1);
connectionFactory.setPo
浏览 2提问于2013-11-15得票数 6
回答已采纳
嗨，我试图用spring的autoconfig rabbitTemplate定义我自己的connctionFactory。首先我尝试了这个：
@Configuration
@EnableRabbit
public class MyConfiguration {
@Autowired
private ConnectionFactory connectionFactory;
@Bean
public RabbitTemplate rabbitTemplate(){
RabbitTemplate template = new RabbitTemplate(connectionFactory)
浏览 4提问于2015-06-22得票数 1
我遇到的问题是:在application.properties中通过spring.profiles.active=development定义的活动概要文件。但是，当我将Spring的环境变量用于getActiveProfiles()时，返回的只是一个空字符串数组。应用程序启动时使用“下面的概要文件是活动的:开发”。感谢你在这方面的任何帮助。下面是一个简单的类，用于检查是否可以检索配置文件。
已经尝试自动加载环境变量，但没有效果。这个类被标记为@Component并实现了EnvirontmentAware。
注:我已经看过几乎每一个关于这个问题的线程，所以请不要标记为欺骗，因为没有解决我的问题。
浏览 1提问于2019-05-24得票数 1
回答已采纳
1回答
我正在使用Python3.6连接到RabbitMQ。该连接使用TLSv1.2协议。设置SSL的连接参数： cxt = ssl.SSLContext(ssl.PROTOCOL_TLSv1_2)
ssl_options = pika.SSLOptions(context=cxt, server_hostname=rabbit_config['HOST'])
conn_params = pika.ConnectionParameters(port=rabbit_config['PORT'],
浏览 79提问于2019-04-30得票数 0
1回答
我想订阅一个使用Solace JMS API的持久主题。但是当我启动我的应用程序时，它抛出了下面的错误： Context_3_ReactorThread INFO com.solacesystems.jcsmp.impl.flow.BindRequestTask -错误响应(503) -超出了持久主题终结点的最大客户端数 我在centos 7上使用solace的最新docker镜像，镜像版本是solace-pubsub-standard (9.1.0.201)。 下面是我的代码： @Bean
public SolConnectionFactory connectionFactory() {
浏览 38提问于2019-07-02得票数 0
1回答
我必须实现一个数据库连接模式。我创建了两个类：
ConnectionFactory
MySQLService
ConnectionFactory:
<?php
class ConnectionFactory {
protected static $connection;
public function getConnection() {
if (!self::$connection) {
self::$connection = new PDO('mysql:host=localhost;dbname=
浏览 3提问于2013-12-18得票数 0
回答已采纳
我正在创建一个rabbitmq连接，希望在onMessage方法中能够访问messageListener工厂配置，这是可能的吗？它对日志记录和其他详细信息很有用。能够记录从其递送消息的vhost将是有帮助的，并且它在消息本身中不可用。下面是我的使用者和配置
public class Consumer implements MessageListener {
@Override
public void onMessage(Message message) {
//how can I get the connection factory configuration whe
浏览 6提问于2017-01-27得票数 0
1回答
我有一个接口扩展函数，如下所示：
import javax.jms.ConnectionFactory
fun ConnectionFactory.foo() {
println("do some stuff")
}
我怎样才能模仿foo函数呢？
请注意，我已经在中看到了类和对象的方法，但是它不起作用。我试过这个：
import io.mockk.classMockk
import io.mockk.every
import org.junit.Test
import javax.jms.ConnectionFactory
class ExtensionFunc
浏览 0提问于2018-04-24得票数 2
回答已采纳
在下面的示例中，在Spring入门指南中，容器bean是如何获得connectionFactory的？Spring自己提供connectionFactory吗？
有5个豆子：
闩锁
接收器
listenerAdapter
模板
容器
首先创建闩锁。然后接收方，因为接收者构造函数需要latch.Then listenerAdapter，因为它需要receiver.Both模板，容器需要connectionFactory。在代码中，我没有找到任何名称为connectionFactory并带有@Bean注释的方法。
@SpringBootApplication
浏览 4提问于2017-04-15得票数 0
回答已采纳
我正在使用Qpid协议向ActiveMQ Artemis的队列发送一条消息，如果我使用以下代码就可以成功
ConnectionFactory connectionFactory = new JmsConnectionFactory("amqp://localhost:5672");
但是，当我使用这种方式时，它将失败：
Context initialContext = new InitialContext();
factory = (ConnectionFactory) initialContext.lookup("ConnectionFactory");
下面
浏览 14提问于2017-07-27得票数 0
如下面的(失败)测试所示，在创建连接时不声明可执行项：
private const val QUEUE = "test"
@SpringBootTest
class ThreadChannelConnectionFactoryTest {
@Autowired
private lateinit var admin: AmqpAdmin
@Test
fun queueExists() {
assertThat(admin.getQueueInfo(QUEUE)).isNotNull
}
@SpringBoot
浏览 3提问于2020-11-17得票数 3
回答已采纳
对于下面的代码，仓库中的Get和update操作可以很好地工作。但是保存操作不会将数据持久化到表中。如果我自己实现Repository，它会工作得很好。在将其替换为扩展ReactiveCrudRepository的接口后，这个问题就开始了。我是不是遗漏了什么？ @SpringBootApplication
public class ReactiveSqlApplication {
public static void main(String[] args) {
SpringApplication.run(ReactiveSqlApplication.class, args);
}
浏览 143提问于2019-01-29得票数 1
1回答
关于这一点，RabbitMQ教程很简单：
ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost("localhost");
connection_ = connectionFactory.newConnection();
channel...
channel.basicPublish...
然而，它如何在智能手机上工作呢？internet连接可能不可用，或在连接时可用，在发布时不可用。
拉布比克能帮我们处理所有事情吗？(如果这件事重要的话，我在Androi
浏览 2提问于2014-04-05得票数 0
回答已采纳
1回答
我想实现Spring AMQP示例，用于使用listener发送和接收Java对象。我试过这个：
发送Java对象
ConnectionFactory connectionFactory = new CachingConnectionFactory("localhost");
AmqpAdmin admin = new RabbitAdmin(connectionFactory);
admin.declareBinding(BindingBuilder.bind(new Queue(QUEUE_PROCESSING_TRANSACTION, false)).to(new Top
浏览 0提问于2018-06-24得票数 0
1回答
我有这样的代码： public class Rabbit
{
public IConnection GetConnection(string hostName, string userName, string password)
{
ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.HostName = "1.2.3.4";
connectionFacto
浏览 27提问于2018-12-17得票数 0
回答已采纳
1回答
我是Spring的新手，我只是尝试使用注释来理解RabbitMQ java配置。这里是示例代码。
发送者代码-
@Component
public class Runner implements CommandLineRunner {
private final RabbitTemplate rabbitTemplate;
private final Receiver receiver;
private final ConfigurableApplicationContext context;
public Runner(Receiver receiver,
浏览 0提问于2018-03-15得票数 0
回答已采纳
2回答
我希望开始使用rabbitmq客户端，从队列接收数据。这个队列是联机的，我拥有创建到它的连接的所有信息：
主机
用户名
密码
虚拟主机
端口
我用java编写了一个应用程序来使用ConnectionFactory类创建连接：
import com.rabbitmq.client.ConnectionFactory;
public class Stats {
public final static String TOKEN = "1234567";
public final static String USER = "u
浏览 0提问于2015-03-26得票数 3
我已经在我的应用程序中实现了ActiveMQ messages，但是每当我在控制台日志中连接到ActiveMQ服务器时，我总是看到以下消息：
10:28:05.282 [ActiveMQ InactivityMonitor WriteCheckTimer] DEBUG o.a.a.t.AbstractInactivityMonitor - WriteChecker: 10000ms elapsed since last write check.
10:28:05.282 [ActiveMQ InactivityMonitor Worker] DEBUG o.a.a.t.AbstractInac
浏览 8提问于2017-08-17得票数 4
我想为CachingConnectionFactory设置SSL连接工厂。我试过这个：
com.rabbitmq.client.ConnectionFactory cf = new ConnectionFactory();
cf.setHost(HOST);
cf.setPort(PORT);
cf.setUsername(USERNAME);
cf.setPassword(PASSWD);
cf.setVirtualHost(VIRTUAL_HOST);
cf.setAutomaticRecoveryEnabled(false);
cf.setConnectionTimeout(10000)
浏览 1提问于2018-06-29得票数 0
我想使用ConnectionFactory进行配置
connectionFactory.Uri =new Uri("rabbitmq://xxx.xx.xx.xx");
connectionFactory.UserName = "12345678io";
connectionFactory.Password = "123456789120er";
并返回给我这个错误=>“错误的方案在AMQP URI: rabbitmq”
浏览 34提问于2020-05-11得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
