Java의 메시지 대기열 샘플 코드 공유

이 글은 주로 Java 메시지 큐의 간단한 구현 코드를 소개합니다. 편집자는 이것이 꽤 좋다고 생각합니다. 이제 이를 여러분과 공유하고 참고용으로 제공하겠습니다. 편집자를 따라가서 살펴볼까요

오늘 우리 채용 정보에 메시지 대기열에 대한 요구 사항이 있는 것을 보고 그것에 대해 생각하고 온라인에서 많이 검색했습니다.

애플리케이션 시나리오를 설명하기 위해 작은 예를 들 수 있습니다.

서버의 처리 용량은 분당 200개이지만 클라이언트는 피크 시간에 분당 1,000개의 메시지를 보낼 수 있습니다. 시간이 지나면 큐로 만든 다음 일반적인 순서로 선입선출(LIFO), 선입선출(FIFO)으로 처리할 수 있으며 상황에 따라 결정하면 됩니다

stack First in last out (LIFO)- -------Java의 해당 클래스 Stack

queue First-In-First-Out (FIFO)---------Java의 해당 클래스 Queue

둘 모두 가능 다음과 같이 Linkedlist로 캡슐화하고 구현했습니다. 제가 직접 작성한 스택의 예입니다

/** 
 * @author 刘伊凡 
 * --------->>>>>>队列的实现-------------- 
 */ 
public class MyStack<T> { 
  private LinkedList<T> storage = new LinkedList<T>(); 
 
  public synchronized void push(T e) {//需要加上同步 
    storage.addFirst(e); 
  } 
 
  public T peek() { 
    return storage.getFirst(); 
  } 
 
  public void pop() { 
    storage.removeFirst(); 
  } 
 
  public boolean empty() { 
    return storage.isEmpty(); 
  } 
 
  @Override 
  public String toString() { 
    return storage.toString(); 
  } 
 
}

다음은 테스트 수업입니다

/** 
 * @author 刘伊凡 
 * 
 */ 
public class StackTest { 
  public static void main(String[] args) { 
    MyStack<String> stack = new MyStack<String>(); 
    for(String s : "the prefect code".split(" ")){//LIFO 
      stack.push(s); 
    } 
    while(!stack.empty()){ 
      System.out.print(stack.peek()+" "); 
      stack.pop(); 
    } 

    System.out.println(); 
    for(char s : "写了个一句话倒起来说的程序".toCharArray()){//用例：正话反说 
      stack.push(String.valueOf(s)); 
    } 
    while(!stack.empty()){ 
      System.out.print(stack.peek()); 
      stack.pop(); 
    } 
  } 
}

과거에 학교에서 꽤 흥미로웠어요. 저녁 파티가 열리면 사회자는 사람들이 무대에 올라 질문에 답하고 상품을 받을 수 있도록 유도합니다. 질문 중 하나는 사회자가 한 문장을 말한 다음 참가자들에게 일어서서 우리 프로그램이 필요해요, 하하, 우리는 배운 것을 속이고 적용하기 위해 java를 사용할 수 있습니다

Message Queue 응용 시나리오, 보충(인터넷에서)

개인적으로 메시지 대기열의 주요 기능은 비동기 처리라고 생각합니다. 주요 목적은 요청 응답 시간과 디커플링을 줄이는 것입니다. 따라서 주요 사용 시나리오는 시간이 많이 걸리고 즉시(동기식) 결과를 메시지로 반환할 필요가 없는 작업을 메시지 큐에 넣는 것입니다. 동시에, 메시지 대기열의 사용으로 인해 메시지 형식이 변경되지 않는 한 메시지의 송신자와 수신자는 서로 접촉하거나 영향을 받을 필요가 없습니다. 즉, 분리 및 요약이 가능합니다.

사용 시나리오 예:

사용자가 소프트웨어에 등록한다고 가정합니다. 서버는 사용자의 등록 요청을 받은 후 다음 작업을 수행합니다.

아닌 경우 사용자 이름과 기타 정보를 확인합니다. 데이터베이스에 사용자 기록을 추가합니다

이메일로 등록하면 등록 성공을 알리는 이메일이 전송됩니다. 휴대폰으로 등록하면 문자 메시지가 전송됩니다.

사용자의 개인 정보를 순서대로 분석합니다. 나중에 그 사람에게 뭔가를 추천하거나 같은 생각을 가진 사람에게 추천하거나

사용자에게 운영 지침이 포함된 시스템 알림을 보냅니다

etc...

하지만 사용자에게는 등록 기능이 있습니다. 실제로 서비스가 제공되는 한 첫 번째 단계만 필요합니다. 클라이언트가 자신의 계정 정보를 데이터베이스에 저장한 후 로그인하여 원하는 작업을 수행할 수 있습니다. 다른 것들도 이 요청에서 완료해야 합니까? 사용자에게 중요하지 않은 일을 귀하가 처리할 때까지 기다리는 것이 사용자의 시간을 들일 가치가 있습니까? 따라서 실제로 첫 번째 단계가 완료된 후 서버는 다른 작업을 해당 메시지 대기열에 넣고 즉시 사용자 결과를 반환할 수 있으며 메시지 대기열은 이러한 작업을 비동기적으로 수행합니다.

또는 많은 수의 사용자가 동시에 소프트웨어에 등록하는 또 다른 상황이 있습니다. 높은 동시성 조건에서는 이메일 인터페이스가 이를 감당할 수 없거나 많은 양의 계산이 발생하는 등 등록 요청에 몇 가지 문제가 발생하기 시작합니다. 정보를 분석할 때 CPU가 가득 차게 됩니다. 사용자 데이터 레코드가 데이터베이스에 빠르게 추가되더라도 이메일을 보내거나 정보를 분석할 때 정체되어 요청 응답 시간이 크게 늘어나거나 시간 초과가 발생할 수 있습니다. 좀 비경제적이에요. 이러한 상황에 직면하면 이러한 작업은 일반적으로 메시지 대기열(생산자-소비자 모델)에 배치됩니다. 메시지 대기열은 이를 느리게 처리하는 동시에 사용자의 다른 기능 사용에 영향을 주지 않고 등록 요청을 빠르게 완료할 수 있습니다.

따라서 소프트웨어의 일반적인 기능 개발에서는 의도적으로 메시지 대기열의 사용 시나리오를 찾을 필요가 없습니다. 대신 성능 병목 현상이 발생하면 처리할 수 있는 비즈니스 로직에 시간이 많이 걸리는 작업이 있는지 확인하세요. 그렇다면 이 문제를 해결하기 위해 메시지 대기열을 도입할 수 있습니다. 그렇지 않으면 메시지 대기열을 맹목적으로 사용하면 유지 관리 및 개발 비용이 증가할 수 있지만 상당한 성능 향상을 달성하지 못하므로 이득을 얻을 가치가 없습니다.

위 내용은 Java의 메시지 대기열 샘플 코드 공유의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!