1. ActiveMQ 소개 먼저 이런 상황을 분석해보세요: 웹사이트에서 쇼핑할 때는 주문을 하고, 송장을 작성하고, 결제를 처리하고, 주문을 이행하고, 배송하는 등 절차를 진행해야 합니다. 하지만 사용자가 주문하면 즉시 "주문에 감사드립니다" 페이지로 리디렉션됩니다. 게다가 지연이 없으면 사용자는 이메일도 받게 됩니다. 전통적인 구현 방식을 사용한다면, 일반적으로 데이터베이스를 운영한 후 다양한 인터페이스와 서비스를 호출해 다양한 응답을 기다리는 방식입니다. 그래서 다음 주문 결과를 보는 데 오랜 시간이 걸리고, 특정 링크에 문제가 있으면 주문 결과가 한동안 보이지 않게 됩니다. 현대 전자상거래에서는 이것이 용납할 수 없습니다. 그러면 ActiveMQ는 이 문제를 매우 잘 해결할 수 있습니다: 사용자가 주문을 넣으면 ActiveMQ에 주문을 제출하라는 호출이 있고, 시스템은 결과 페이지로 돌아가 전체 주문 프로세스가 동기식으로 호출되지 않고, 백그라운드 JOB이 채팅 및 실행에 들어가도록 합니다. 프런트 데스크 주문량이 많으면 각 주문을 한 번만 호출하면 되는데, 백그라운드 사무실이 한 번에 다 처리할 수 없다는 건가요? 천천히 하세요, 아무도 강요하지 않고, ActiveMQ에서 주문이 줄을 서 있어서 짜증내지 않을 겁니다. 이 시나리오는 메시지 큐라고 불리는 캐시 큐에 이상적이며, 많은 제품이 구현할 수 있고, 참고로 다음 질문에 답해줍니다: 데이터베이스보다 훨씬 빠릅니다.
이 글은 기본부터 시작하여 함께 학습합니다. 이 글의 시스템 운영 환경인 Window7 32비트
2. ActiveMQ 공식 웹사이트 다운로드 주소: http://activemq.apache.org/
3.运行ActiveMQ解压缩apache-activemq-5.10.0-bin.zip，然后双击apache-activemq-5.10.0inwin32activemq.bat运行ActiveMQ程序。
콘솔 출력의 마지막 문장인 "모든 MBean 접근이 허용된다"를 참고하여 스타트업이 성공했음을 증명하세요.
ActiveMQ를 시작하면 브라우저를 통해 로그인할 수 있습니다: http://localhost:8161/admin/ 인증 시 기본 사용자 이름은 admin, 비밀번호는 admin입니다
(전제는 Java 환경이 설치되어 있다는 것입니다)
.NET 버전의 Dll:Apache.NMS-1.6.0-bin.zip과 Apache.NMS.ActiveMQ-1.6.4-bin.zip 동시에 다운로드하세요
여기에서 모두 다운로드하세요: http://archive.apache.org/dist/activemq/apache-nms/1.6.0/
3. 첫 번째 ActiveMQ 예시는 C#을 사용하여 정보의 출처, 즉 프로듀서를 작성합니다:
인터페이스는 매우 간단합니다. 레이블, 텍스트박스, 버튼 하나, 그리고 Apache.NMS.dll와 Apache.NMS.ActiveMQ.dll 참조를 추가하고, 위의 다른 두 다운로드 패키지에서 찾아보세요. 버전 번호도 주의 깊게 확인하세요.
메시지를 보내기 위해 버튼을 클릭할 수 있으며, 이 메시지들은 ActiveMQ에 임시로 저장되며, 비밀번호를 요청한 웹페이지에 로그인해 확인할 수 있습니다.
그다음 수신자, 즉 소비자를 다음과 같이 작성합니다:
또한 두 개의 DLL에 대한 참조도 추가하세요. 인터페이스는 단일 레이블로 매우 간단합니다:
시작하자마자 이 메시지들은 여기서 수신되었고, 서버 측 메시지들은 삭제된 것을 알게 될 것입니다.
4. 요약 위에서 언급한 내용은 P2P 메시지 큐를 구현했으며, 이 큐는 일시적으로 저장되어 처리될 때까지 기다리며, 처리 후 메시지가 사라져 전달되고 손실되거나 드랍되지 않도록 보장합니다. 이 모드는 제한된 경우에만 사용할 수 있으며, 고객은 한 가지 특급 배송 형태의 경우만 가질 수 있어 주문 처리 요건을 충족할 수 없습니다. 이유는 매우 간단합니다: 블랙리스트 검사 링크가 이 주문 정보를 얻고, 검토 링크는 얻을 수 없습니다. 다음 섹션에서는 "메시지 그룹 전송"을 함께 배우는데, 즉 주문이 도착한다고 외치고 모두가 분주해지기 시작합니다...
참고: 이 기사와 기사 메시지는 재게재되었습니다. Properties.SetString("filter","demo"); 이 기능은 설정할 필요가 없습니다!!
|
게시됨 2017. 1. 9. 오후 2:41:52
|
|
|
|
