为什么要在5.x弃用consumeThreadMax
Chưa có ai nhận issue này.
Đánh giá
- Độ khó
- 5/5
- Thời gian dự kiến
- Hơn một tuần
- Mức phù hợp với người mới
- 30/100
- Loại issue
- Tính năng
- Độ rõ ràng
- Cần làm rõ
- Mức độ hoạt động
- Sôi nổi
- Công nghệ
- java
- Lĩnh vực
- distributed-systems
Hướng nghiên cứu
Issue không nêu tên tệp, bài kiểm thử hay điểm vào nào. Hãy bắt đầu bằng cách lần theo cấu hình consumer-thread của 5.x và lý do loại bỏ consumeThreadMax, sau đó xem xét các trường hợp nhiều topic và topic đã hợp nhất được mô tả. Để được xem là hoàn tất, cần có một thiết kế đã được thống nhất và quyết định của maintainer về hành vi động của thread-pool.
Do mô hình lập chỉ mục viết ra từ nội dung của issue.
Mô tả
由于consumeThreadMin和consumeThreadMax在5.x版本当中被弃用，我有几个问题
- 由于线程数量无法再设置核心线程数以及最大线程数，线程数量只能设置为固定线程，假设我设置为固定20，如果我在多Topic的情况下，一旦项目启动并创建了消费者，那么创建的消费者线程数量就将会是 n(topic数量) * 20, 这样就会有大量的线程进入Waiting状态并浪费资源
- 消费者线程数调低会导致业务高峰期消费不及时
- 如果按照上述逻辑，并且合并Topic也会有问题，如果同一Topic内，多个业务逻辑比如A、B、C，其中A会产生大量消息，B、C很少，如果A产生了大量消息并导致堆积会造成B、C也造成堆积
所以结合上述的问题，为什么不设计成允许动态线程池，低峰期自动降低线程数，高峰期自动开辟线程到最大线程数，队列满之后的线程认为来不及处理不处理呢，虚心请教一下
- Ngôn ngữ chính
- Java
- Star
- 2.3k
- Fork
- 941
- Chỉ số merge pull request
- Không có pull request nào được merge trong 30 ngày
Chuẩn bị môi trường
- Không có Dockerfile hay tệp Docker Compose
- Có mẫu pull request
- Không có hướng dẫn đóng góp
Bắt đầu từ đâu
- Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
- Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
- Fork repository và làm thay đổi trên một nhánh.
- Mở pull request có tham chiếu số hiệu của issue.
Issue khác của apache/rocketmq-spring
-
[Bug] RocketMQClientTemplate.receiveAsync closes the shared SimpleConsumer, breaking all subsequent operationsCó thể đã có người làm @wang-jiahua đã nhận 58 ngày trước. Đang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 88/100
apache/rocketmq-spring#780 · 3 bình luận ·
-
编译报错Đang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 72/100
apache/rocketmq-spring#692 · 1 bình luận ·
-
消费者注册时候对nameserver取值有点问题Đang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 68/100
apache/rocketmq-spring#678 · 2 bình luận ·
-
Độ khó 1/5 Dưới một giờ Mức phù hợp với người mới 82/100
apache/rocketmq-spring#670 · 1 bình luận ·
-
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 62/100
apache/rocketmq-spring#609 · 3 bình luận ·
Tất cả issue của apache/rocketmq-spring
Issue tương tự
-
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 82/100
Maintainer thường phản hồi trong vòng 1 ngày
-
Độ khó 1/5 Dưới một giờ Mức phù hợp với người mới 88/100
quarkusio/quarkus-agent-mcp#302 ·
Maintainer thường phản hồi trong vòng 2 ngày
-
build
Độ khó 1/5 Dưới một giờ Mức phù hợp với người mới 85/100
MetricsHub/metricshub-community#1472 ·
Maintainer thường phản hồi trong vòng 1 ngày
-
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 82/100
Maintainer thường phản hồi trong vòng 1 ngày
-
IdentityArrayObjectSet iterator remove may throw ArrayIndexOutOfBoundsExceptionCó thể đã có người làm @jiteshkhatri11 đã nhận hôm nay. Đang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 72/100
javapathfinder/jpf-core#660 · 1 bình luận ·