내 응용 프로그램에서 ActiveMQ를 내장 된 in-process 메시지 대기열로 조사 중이지만 그와 같은 응용 프로그램을 시작하는 방법에 대해 조금 꼼짝도하지 않습니다. . 나는이의 간단한 버전을 조립하기 위해 노력했습니다 configureBroker()
broker.start()
createProducer (broker)
producer.sta
이 방법에 대해 실제로 확신 할 수는 없지만 사용자 지정 클래스 내에서 발생하는 이벤트를 구독하고 이상적으로는 대기열에 넣고 먼저 처리해야합니다. 그들이 들어올 때 밖으로 나간다. 나는 Queue<T>을 알고 있으며 이것을 사용해야한다고 생각 하는가? 내 질문은 이벤트 처리기에 내 메시지가 수신되면, 단순히 Enqueue() 대기열에 있습니까? 그렇다면 새
저는 WebSphere MQ의 새로운 기능입니다. 나는 IBM의 .NET 클래스 (IBM.WMQ)를 사용하여 요청 메시지를 보낸 다음 응답 메시지를 받는다. MQMessage 오브젝트에는 다양한 데이터 유형에 대한 여러 Writexxx 메소드가 있습니다. 요청 메시지에 다양한 데이터 요소를 써야합니다. 내 질문은 각 개별 데이터 요소에 대해 적절한 Writ
나는 Musicbrainz 웹 서비스에 요청하는 앱을 개발 중입니다. musicbrainz 매뉴얼에서 초당 하나의 요청을 webservice에 보내지 않거나 클라이언트 IP가 차단됩니다. 이 제한을 서비스 클라이언트에 투명하게 만들기 위해 어떤 아키텍처를 제안하십니까? 메서드 (예 : getAlbuns)를 호출하고 싶습니다. 마지막 요청 후 1 초만 요청해
현재 IP를 통해 텔레콤 응용 프로그램을 테스트하고 있습니다. Raw Socket을 열고 원격 측에서 메시지를받습니다 (msgrate @ 750 + msgs/IP를 제외한 약 180 바이트의 두 번째 크기). Raw 소켓 위에 SCTP (TCP처럼)라는 레이어가 있으며,이 레이어는 모든 패킷을 잃어 버렸음을 나타냅니다. 이제 우리는 수신 노드에서 Wires
Java와 관련된 실용적인 시나리오, 소켓 프로그램에 대해 연구 중입니다. 기존 시스템과 예상 시스템은 다음과 같습니다. 기존 시스템 - 시스템은 특정 조건이 충족되는지 확인합니다. 그렇다면 보낼 메시지를 작성하여 대기열에 넣으십시오. 큐 프로세서는 별도의 스레드입니다. 주기적으로 큐에 항목이 있는지 여부를 확인합니다. 항목 (메시지)을 찾으면 메시지를 원
여러 사용자가 약 100,000 개의 레코드에 액세스하려고하는 빠른 대기열을 구현하는 가장 좋은 방법은 무엇입니까? 한 명의 사용자 만 하나의 고유 한 행을 얻을 수 있습니다. 지금 메신저 데이터베이스 (파이어 버드)를 사용하여 메신저 있지만 문제가 많은 교착 상태/높은 데이터베이스로드가 있습니다.