Comments (9)
从你的想象看,同样的客户端(rocketmq-spring), 对不同的broker服务端现象不一样。应该不是客户端的问题,可能与你连接阿里云香港region的网络配置有关。如果有具体环境,我们可以验证一下。
另外,请把标题改成英文的,所有RMQ的issue提问建议使用英文,至少标题使用英文,谢谢
from rocketmq-spring.
遇到的同样的问题,请问这个开源的SDK是否能够兼容阿里云的Rocket MQ?
from rocketmq-spring.
我再找阿里云客服处理了
from rocketmq-spring.
从你的想象看,同样的客户端(rocketmq-spring), 对不同的broker服务端现象不一样。应该不是客户端的问题,可能与你连接阿里云香港region的网络配置有关。如果有具体环境,我们可以验证一下。
另外,请把标题改成英文的,所有RMQ的issue提问建议使用英文,至少标题使用英文,谢谢
需要什么那些相关信息?
from rocketmq-spring.
@vodcms 你们具体的调用配置是指配置name-server吗?还是这个公有云访问需要配置配置 AK, SK等信息?如果是纯Aliyun的公网访问方式还需要功能加强一下才能支持,这个我们会在5月份看一下尽快推出。
from rocketmq-spring.
@vodcms 你们具体的调用配置是指配置name-server吗?还是这个公有云访问需要配置配置 AK, SK等信息?如果是纯Aliyun的公网访问方式还需要功能加强一下才能支持,这个我们会在5月份看一下尽快推出。
阿里云公网连接没有任何毛病,但是使用香港私有网络连接就出现我提交的问题,AK,SK信息都有的。
我现在遇到在使用公网做项目测试环境,没问题,但是部署到私有网络忘记就崩溃了。导致项目延期,虽然我们可以自己实现整合阿里的私有SDK,不过我觉得咱们这个实现的优雅多了。要赞
from rocketmq-spring.
@vodcms @taroyutao RocketMQ Spring 2.0.3版本已经发布了,支持4.5.1客户端无缝上云, 可以使用新版的spring验证一下了。
from rocketmq-spring.
@ShannonDing 文档有吗
from rocketmq-spring.
@ShannonDing I am using the latest version or will have the same problem
<rocketmq.starter.version>2.0.3</rocketmq.starter.version>
rocketmq:
name-server: XXX.mq-internet-access.mq-internet.aliyuncs.com:80
access-channel: CLOUD
producer:
access-key: XXX
secret-key: XXX
group: XXX%XXX
See http://rocketmq.apache.org/docs/faq/ for further details.; nested exception is org.apache.rocketmq.client.exception.MQClientException: Send [3] times, still failed, cost [1227]ms, Topic: TEST, BrokersSent: [qdinternet-06, qdinternet-05, qdinternet-06]
See http://rocketmq.apache.org/docs/faq/ for further details., mergedContextConfiguration = [MergedContextConfiguration@4f4c4b1a testClass = NativeProducerTest, locations = '{}', classes = '{class com.wjh.common.message.ApplicationTest}', contextInitializerClasses = '[]', activeProfiles = '{}', propertySourceLocations = '{}', propertySourceProperties = '{org.springframework.boot.test.context.SpringBootTestContextBootstrapper=true}', contextCustomizers = set[org.springframework.boot.test.context.filter.ExcludeFilterContextCustomizer@1d296da, org.springframework.boot.test.json.DuplicateJsonObjectContextCustomizerFactory$DuplicateJsonObjectContextCustomizer@557caf28, org.springframework.boot.test.mock.mockito.MockitoContextCustomizer@0, org.springframework.boot.test.web.client.TestRestTemplateContextCustomizer@1f2586d6, org.springframework.boot.test.autoconfigure.properties.PropertyMappingContextCustomizer@0, org.springframework.boot.test.autoconfigure.web.servlet.WebDriverContextCustomizerFactory$Customizer@2cd76f31], contextLoader = 'org.springframework.boot.test.context.SpringBootContextLoader', parent = [null]], attributes = map[[empty]]], class annotated with @DirtiesContext [false] with mode [null], method annotated with @DirtiesContext [false] with mode [null].
org.springframework.messaging.MessagingException: Send [3] times, still failed, cost [1227]ms, Topic: TEST, BrokersSent: [qdinternet-06, qdinternet-05, qdinternet-06]
See http://rocketmq.apache.org/docs/faq/ for further details.; nested exception is org.apache.rocketmq.client.exception.MQClientException: Send [3] times, still failed, cost [1227]ms, Topic: TEST, BrokersSent: [qdinternet-06, qdinternet-05, qdinternet-06]
See http://rocketmq.apache.org/docs/faq/ for further details.
at org.apache.rocketmq.spring.core.RocketMQTemplate.syncSend(RocketMQTemplate.java:194)
at org.apache.rocketmq.spring.core.RocketMQTemplate.syncSend(RocketMQTemplate.java:126)
at org.apache.rocketmq.spring.core.RocketMQTemplate.syncSend(RocketMQTemplate.java:114)
at org.apache.rocketmq.spring.core.RocketMQTemplate.doSend(RocketMQTemplate.java:514)
at org.apache.rocketmq.spring.core.RocketMQTemplate.doSend(RocketMQTemplate.java:53)
at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109)
at com.wjh.common.message.NativeProducerTest.sendMessage(NativeProducerTest.java:30)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.springframework.test.context.junit4.statements.RunBeforeTestExecutionCallbacks.evaluate(RunBeforeTestExecutionCallbacks.java:74)
at org.springframework.test.context.junit4.statements.RunAfterTestExecutionCallbacks.evaluate(RunAfterTestExecutionCallbacks.java:84)
at org.springframework.test.context.junit4.statements.RunBeforeTestMethodCallbacks.evaluate(RunBeforeTestMethodCallbacks.java:75)
at org.springframework.test.context.junit4.statements.RunAfterTestMethodCallbacks.evaluate(RunAfterTestMethodCallbacks.java:86)
at org.springframework.test.context.junit4.statements.SpringRepeat.evaluate(SpringRepeat.java:84)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:251)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:97)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61)
at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:190)
at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)
at com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:47)
at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:242)
at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70)
Caused by: org.apache.rocketmq.client.exception.MQClientException: Send [3] times, still failed, cost [1227]ms, Topic: TEST, BrokersSent: [qdinternet-06, qdinternet-05, qdinternet-06]
See http://rocketmq.apache.org/docs/faq/ for further details.
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:638)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1310)
at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:358)
at org.apache.rocketmq.spring.core.RocketMQTemplate.syncSend(RocketMQTemplate.java:188)
... 36 more
Caused by: org.apache.rocketmq.client.exception.MQBrokerException: CODE: 1 DESC: com.aliyun.openservices.ons.api.impl.authority.exception.AuthenticationException: valid resource owner failed. maybe the resource TEST not created, com.alibaba.ons.open.auth.validator.PermissionValidator.check(PermissionValidator.java:72)
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
at org.apache.rocketmq.client.impl.MQClientAPIImpl.processSendResponse(MQClientAPIImpl.java:565)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:361)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:343)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:297)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:831)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:557)
... 39 more
aliyun provided ons-client can be used normally
from rocketmq-spring.
Related Issues (20)
- 配置文件不能自动装配RocketMQAutoConfiguration HOT 2
- why setRequestTimeout use Duration.ofDays
- Support Springboot 3.X
- Release blocker of RocketMQ-Spring 2.3.0 HOT 1
- will handleMessage be public,so users can do some intecept before consumeMessage
- Is there a plan to release a version that is compatible with Springboot 3
- 在rocketmq服务端未启动的情况下,启动springboot报错 HOT 4
- 5.0 grpc client add config enableSsl
- Compilation failed
- Make v5 sample logs to output normally
- Exclude annotations-api to make spring-boot start normally
- Bump rocketmq version to 5.2.0
- RocketMQ监听者收到消息后发送到其他Topic时报空指针异常
- Native-image之后无法连接namesvr,但是在jdk环境里面可以连接
- The code for version 2.3.0 seems to be fine now. Could you package it when you have time and upload it to the Maven Central Repository? HOT 3
- Upgrade samples version to 2.3.1-SNAPSHOT
- BUG REPORT:rocketmq-spring-boot-2.2.3.jar HOT 3
- sendAndReceive方法能否接收到响应,对于消费者和生产者的启动顺序是否有要求? HOT 1
- A project cannot use the same consumer group HOT 3
- Document what the difference between rocketmq-spring-boot-starter and rocketmq-v5-client-spring-boot-starter
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from rocketmq-spring.