腾讯云消息队列11月产品月报：RocketMQ 5.x国际站正式发布

前端

2022-11-23 17:07:16

RocketMQ 5.x 国际站：引领企业级消息传输的新纪元

全面赋能全球化企业级应用

随着数字化浪潮席卷全球，企业级应用迫切需要快速、可靠的消息传输服务。RocketMQ 5.x 国际站的推出应运而生，全面赋能全球化企业级应用，开辟消息传输新格局。

亮点解析：满足不同应用场景需求

1. 全系列集群覆盖： 从基础版到企业版，满足不同应用场景的需求，从一般应用到对可靠性和稳定性要求极高的金融、证券和电商等行业。

2. 多地域部署： 中国大陆、美国、新加坡和日本等全球部署，实现全球化消息传输，消除地理限制。

3. 弹性伸缩： 根据业务高峰需求自动扩缩容，保障高峰期消息传输顺畅，避免瓶颈。

4. 安全可靠： 消息加密、认证和签名，确保消息传输的安全性和完整性。

引领企业级消息中间件新时代

RocketMQ 5.x 国际站基于 RocketMQ 5.x 核心技术打造，继承了其稳定性、高性能和低延时优势，针对全球化企业级应用的需求进行了优化和增强。

1. 稳定可靠： 经过千万级集群验证，保障消息传输的稳定性和可靠性。

2. 高性能： 亿级消息吞吐量，满足大规模消息传输需求。

3. 低延时： 毫秒级消息传输延时，确保消息快速送达。

成为全球化企业级应用消息传输最佳选择

RocketMQ 5.x 国际站以其卓越的技术实力和针对全球化应用需求的优化，成为全球化企业级应用消息传输的最佳选择。

代码示例：

import com.tencentcloudapi.rocketmq.v20190807.models.*;
import com.tencentcloudapi.common.Credential;
import com.tencentcloudapi.common.exception.TencentCloudSDKException;
import com.tencentcloudapi.common.profile.ClientProfile;
import com.tencentcloudapi.common.profile.HttpProfile;

public class CreateTopic {
    public static void main(String[] args) {
        try {
            // 实例化一个认证对象，入参需要传入腾讯云账户secretId，secretKey
            Credential cred = new Credential("secretId", "secretKey");

            // 实例化一个http选项，可选，无特殊需求时可以跳过
            HttpProfile httpProfile = new HttpProfile();
            // 设置代理（可无）
            httpProfile.setProxyHost("127.0.0.1");
            httpProfile.setProxyPort(80);

            // 实例化一个client选项，可选，无特殊需求时可以跳过
            ClientProfile clientProfile = new ClientProfile();
            clientProfile.setHttpProfile(httpProfile);

            // 实例化要请求产品的client对象,clientProfile是可选的
            RocketmqClient client = new RocketmqClient(cred, "ap-guangzhou", clientProfile);

            // 实例化一个请求对象,每个接口都会对应一个request对象
            CreateTopicRequest req = new CreateTopicRequest();

            // 填写参数
            Topic topic = new Topic();
            topic.setTopicId("testTopic");
            req.setTopic(topic);
            // ... 其他参数

            // 返回的resp是一个CreateTopicResponse的实例，与请求对象对应
            CreateTopicResponse resp = client.CreateTopic(req);

            // 输出结果
            System.out.println(resp.getTopicId());
        } catch (TencentCloudSDKException e) {
            System.out.println(e.toString());
        }
    }
}