기존 msg 기반 소프트웨어 마이그레이션을 위해 NATS를 평가 중입니다 msg 시간 초과 예외 및 과부하에 대한 설명서를 찾지 못했습니다. 예를 들어 는 : 가입자 후 이 되어 선택했다, 그것은 게시자에 의해 게시 시간 제한 설정을 알고 있습니까? 추가 시간 연장을 통보하는 것이 가능합니까? 선출 가입자가 일부 DBMS 연결이 누락과 메시지를 NATS 서
현재 프로젝트를 위해 TIBCO RV를 NATS IO로 마이그레이션하려고합니다. NATS IO가 어떤 내부 아키텍처로 인해 웹 사이트의 http://nats.io/about/에서 주장하는 것처럼 뛰어난 성능을 제공하는지 알고 싶습니다. nat의 내부를 설명하는 온라인 자원을 찾을 수 없었습니다. 아무도 이것 좀 도와 줄래?.
내가 NATS을 만드는 오전 랭 큐 가입자 클라이언트 이동 nc.QueueSubscribe("foo", "my_queue", func(msg *nats.Msg) {
log.Printf("Message :%s", string(msg.Data))
})
구독 여러 큐와 큐 아니. 예를 들어 내가 "foo"라는 제목으로 10 개의 메시지를 보냈다면
원격 장치에서 위치 정보를받는 Mosquitto 브로커가 있습니다. 이 데이터를 다른 마이크로 서비스에서 처리하려면 어딘가에 저장해야합니다. 현재 브로커에 가입하고 일괄 적으로 Postgres 데이터베이스에 쓰는 Node.js 프로세스가 있습니다. Devices -> Mosquitto -> DB writer -> (source-of-truth) Postgr
파이썬 Asyncio NATS.io를 순차적으로 실행하는 데 문제가 있습니다. 나는 두 클래스가 있습니다 : Account과 Bridge 계정은 응용 프로그램의 논리를 가지고 있으며 NATS.io를 통해 외부 서비스와 함께 생각한 것입니다 (Bridge). Main 파일 : loop = asyncio.get_event_loop()
account = Acc
NATS를 사용하고 있으며 3 개 이상 노드의 클러스터링을 사용합니다. 우리는 여러 생산자와 많은 소비자를 보유하고 있습니다. 메시지 크기는 작지만 (~ 100bytes) 처리량은 다소 높습니다. ~ 40k/초. 모든 트래픽은 2x10gbps 본드 내부 네트워크에 있습니다. 더 많은 노드로 클러스터를 확장하면 클러스터 처리량에 도움이 될지 궁금했습니다. 더
큰 응용 프로그램을 여러 프로세스로 나누고 각 프로세스가 서로 통신하기를 원합니다. 이제는 동일한 서버에 있지만, 나중에 동일한 로컬 네트워크에있는 여러 서버에 여러 프로세스가있어 서로 통신해야합니다. (하나의 서버에서 서비스를 의미하며 동일한 vpc의 다른 서버에서 서비스를 의미 함) 이렇게 .. 내 원시 옵션은 tcp 또는 unix sockets입니다.