Search
Ask A Question
Home / Questions for Category: “message-queue”
Avatar
0
Nguyen Thai Son Beginner
Asked: 1684883414000 In: Message Queue
Nguyen Thai Son Beginner Asked: 1684883414000 In: Message Queue
Cách xử lý bất đồng bộ các message trong message queue
Hiện tại thì e đang design 1 cái architecture overview nhưng đang khá khoai ở chỗ việc xử lý bất đồng bộ đống message.<p> Bài toán đưa ra là: </p> <p> user upload file csv lên s3 </p> <p> s3 trigger lambda(producer) </p> <p> lambda (producer) gửi 1 cái message dạng như "starting: job_id" vào "Upsert" queue </p> <p> lambda (producer) lấy file csv và xử lý từn
Answer
Avatar
0
Hihi Teacher
Asked: 1664177577000 In: Message Queue
Hihi Teacher Asked: 1664177577000 In: Message Queue
Đa luồng với Kafka Consumer
Tks a vì câu trả lời ! <p> </p> <p> Em có dùng <strong>@KafkaListener</strong> để nhận tin nhắn sau đó gửi gmail (tốn nhiều thời gian) cho user.Em dùng đa luồng cho chức năng này để giải quyết vấn đề treo thread khi xử lý trong listener (do listener mặc định có 1 thread ) </p> <p> </p> <p> Em có 2 lựa chọn : </p> <ol> <li>Như em nói ở trên dùng <strong
Answer
Avatar
1
Lâm Văn Đời Beginner
Asked: 1664004873000 In: Message Queue
Lâm Văn Đời Beginner Asked: 1664004873000 In: Message Queue
Ưu /khuyết điểm của Message Queue
Chào mọi người, em có câu hỏi là: <p> </p> <strong>Tất cả ưu điểm/khuyết điểm (nếu có)</strong> của mẫu thiết kế gửi message 1 cách bất đồng bộ qua MQ trung gian là gì ạ ?
Answer
Avatar
1
Lâm Văn Đời Beginner
Asked: 1664001623000 In: Message Queue
Lâm Văn Đời Beginner Asked: 1664001623000 In: Message Queue
Hỏi về việc gửi tin nhắn qua Message Queue (RabbitMQ,Kafka)
<em>Xin chào mọi người,</em> <p> </p> <p> Theo em được biết thì trong 1 hệ thống <em><strong>Microservices</strong> </em>thì các chức năng như gửi Mail, SMS cho khách hàng thì sẽ được tách thành 1 service mới.Khi cần gửi mail thì sẽ gửi 1 message đến MQ trung gian (Kafka,RabbitMQ,..) chứ không gửi theo kiểu request như thông thường. </p> <p> </p> <p> Em
Answer
Avatar
1
Hihi Teacher
Asked: 1659694287000 In: Message Queue
Hihi Teacher Asked: 1659694287000 In: Message Queue
Thự tự tin nhắn trong Kafka
Chào mọi người, <p> </p> <p> Ví dụ trong Kafka e tạo <strong>1 topic</strong> gồm có  <strong>5 partition.</strong>Theo em hiểu thì khi 1 Consumer nhận message từ topic thì sẽ nhận được từ message từ tất cả partition của topic đó. </p> <ol> <li>Em muốn hỏi là <strong>Consumer</strong> khi nhận các message từ Kafka (<em>nhiều</em> <em>partition</em>) thì c
Answer
Avatar
1
tvd12 Enlightened
Asked: 1657092837000 In: Message Queue
tvd12 Enlightened Asked: 1657092837000 In: Message Queue
EzyKafka khác gì thư viện kafka official?
Hi anh, anh có thể brief qua ezykafka của monkeys có điểm gì nổi bật hơn thư viện official k ạ. Em muốn hiểu rõ hơn về ưu điểm/nhược điểm của ezykafka mà k thấy docs có ghi?
Answer
Avatar
0
tvd12 Enlightened
Asked: 1653804622000 In: Message Queue
tvd12 Enlightened Asked: 1653804622000 In: Message Queue
Start rabbitmq localhost với docker
Start rabbitmq localhost với docker
Answer
Avatar
0
Nguyễn Thái Sơn Professional
Asked: 1637960222000 In: Message Queue
Nguyễn Thái Sơn Professional Asked: 1637960222000 In: Message Queue
kafka và lợi ích
Mục đích hiện tại a sử dụng Kafka để làm gì ạ, có nên thay thế bằng message queue khác như activeMQ k ạ ?
Answer
Load More Questions
Ask A Question
  • Questions 937
  • Answers 2.0K
  • Best Answers 115
  • Users 405

Related Questions

Recent Activities

Show All Activities

Top Members

Trending Tags

php laravel react-native qr stresstest thiết kế tầng trong dự án controllerservice serialization wordpress xss programming-language facebook vietqr network room database restful map video call tcp webrtc câu hỏi excel-object-mapper vuejs jquery đồ án tốt nghiệp lỗi font oracle postman cron elasticsearch di ioc format json get file zip zip file resttemplate design patterns architecture scheduled spring boot datetime #formatdate paginaiton microservices communication multi-threading synchronize otp message send mail ssl email send email jsonproperty join json to object scheduled solution spring websocket cors refactor export compliance config-css spring websocket stream api webflux mobile push-noti jenkins repository replica jotform refresh token access token maria db junit-test gorilla procedure filter exception null exception handler upload resilence4j bucket4j readmoretextview regex email qrcode list .net .net oop partition oop c# .net executor threadpool mq message queue app background h2 database gallery deadlock transaction monitoring main jsp servlet tomcat node.js watermark pdf excel profile properties image authentication plugin udp access app project management estimation database migration migration crawl data graduation thesis utf-8 file validate date connection pool thread pool concurrent convert date to number load balancer nginx synchronized lock graphql stress test test json file networking handy terminal study computer science webassembly assembly nan cookie session mail template mail cosmos-sdk push notification socket server round robin jetbrains validate btree glide floating point artificial intelligence ai private_key duration hyperloglog gateway dns exception handle transfer deploy contract uniswap s3 web ezymq-kafka ezyredis soap transfer git mongo integration-test branch boot-nodes springwebflux mysql index lưu trữ dữ liệu lớn spring-boot-test macos apache poi guide keycloak queue multiple tenant spring security extensions pancakeswap structure trong spring boot postgresql totp n cloud reliability python golang bash script messaging reactive roadmap anti-flooding cosmos jvm abstract class interface log4j non-blocking io career path singleton web3 client zookeeper soft delete centos ansible binding tracking location socket optimize resource eclip naming convention naming game-room game-server log4j-core jsp &amp; servlet java core system environment variables load-balancing pgpool datasource spring data jpa schedule thread rest grapql asyncawait multithread math vector hibernateconfig javaw sjis shift jis stream blog java spring nodejs hibernate ipfs issue build bundle vue cli vue webpack fulltextsearch view sql css html dex decentralized exchange ethereum login javascript keep promise https nft game login thymeleaf erc721 contract erc20 web3 smart contract ropssten ropsten metamask windows 11 bitcoin eth ethereum flutter isolate backend nestjs java web springsecurity machine learning backend spring aop winforms deep learning model spring redis request pre nio io batch unit test slack log indexing sql server devops cors big project work frontend api cache draw.io content-disposition reactjs download datastructure javacore distraction programing callback async promise threadjava unity orm rust pointer panic merge commit .net core js kerberos security go netcore sosanh rabbitmq grpc ezyhttp python unicode front-end fe docker buffered server exyfox career spring-jpa jpa du học job bean spring reactjs fullstack c# kotlin sse websocket mysql springboot rxjava future push message android recyclerview android cast intellij maven netty multithreading msgpack json design-pattern library spring boot redis hazelcast atomicboolean volatile storage it git caching chat game nft blockchain freetank game-box jwt microservice search kafka get upload file download http opensource cloud languague programming database pagination editor stackask question ezyfox-boot ezyfox-server ezyfox phỏng vấn java ezyfoxserver