Apache Mina 연구 노트(3) - IoService

이 장에서는 서버와 클라이언트의 모든 I/O 서비스를 제공하는 기본 클래스인 MINA의 IoService에 대해 설명합니다. 이는 피어와 메시지를 보내고 받고 세션, 연결 등을 관리하는 데 사용됩니다.

서버측에서는 IoAcceptor, 클라이언트측에서는 IoConnector로 구현한 인터페이스입니다.

이 인터페이스를 다음 부분에서 소개하겠습니다.

IoService 소개
IoService 세부 정보
IoAcceptor
IoConnector

IoService 소개

IoService는 Mina 프레임워크에서 기본 I/O 서비스를 제공하고 I/O 세션을 관리합니다. 미나에게 있어 매우 중요한 부분입니다.

위 그림에서 언급했듯이 IoService에는 많은 책임이 있습니다.

세션 관리
필터 체인 관리
핸들러 호출
통계 관리
청취 관리
통신 관리

이 인터페이스의 메서드:

getTransportMetadata();

IoAcceptor 또는 IoConnector가 실행 중일 때 이 메서드는 전송된 메타데이터를 반환합니다. , 일반적으로 이름(nio, apr, txtx), 연결 유형(연결 지향 또는 연결 없음)을 포함합니다.

addListener

지정된 이벤트를 수신하기 위해 IoServiceListener를 추가할 수 있습니다.

removeListener

지정된 IoserviceListener를 제거합니다

isDisposing

서비스가 폐기된 경우 서비스 상태를 반환

isDisposed

서비스가 폐기된 경우 서비스 상태를 반환

dispose

서비스에서 요청한 모든 리소스를 해제하는 데 사용됩니다. 사용자는 먼저 위의 두 가지 방법을 사용하여 서비스가 완전히 폐기되었는지 확인해야 합니다. 서비스를 종료하려면

getHandler

이 메소드를 호출해야 합니다.

setHandler

서비스와 관련된 메소드를 반환합니다. 서버가 요청을 받는 문제를 해결하기 위해 IoHandler는 프로그램 로직을 포함하는

getSessionConfig

세션 구성을 반환합니다.

getFilterChainBuilder

필터를 반환합니다. 필터링을 추가해야 할 때 체인 빌더를 추가해야 할 때 이 메소드를 호출해야 합니다.

IoService 세부 정보

Ioservice 이 인터페이스는 MINA의 두 가지 중요한 클래스인 IoAcceptor와 IoConnector로 구현됩니다. 서버 측에서는 IoAcceptor를 선택하고, 클라이언트 측에서는 IoConnector를 선택해야 합니다.

IoAcceptor

MINA에는 이미 구현된 클래스가 있습니다:

NioSocketAcceptor: 비차단 소켓 전송 IoAcceptor
NioDatagramAcceptor: 비차단 UDP 전송 IoAcceptor
AprSocketAcceptor: APR을 기반으로 하는 차단 소켓 전송 IoAcceptor
VmPipeSocketAcceptor: VM 내 IoAcceptor

필요한 IoAcceptor를 선택하세요.

아래 그림은 IoAcceptor 클래스와 인터페이스

IoConnector

NioSocketConnector : 비차단 소켓 전송 IoConnector
NioDatagramConnector : 비차단 UDP 전송 IoConnector
AprSocketConnector : APR 기반의 차단 소켓 전송 IoConnector
ProxyConnector : 프록시 지원을 제공하는 IoConnector
SerialConnector : 직렬 전송을 위한 IoConnector
VmPipeConnector : in -VM IoConnector

다음은 요약한 예입니다.

예를 들어 VM IoConnector를 생성하려는 경우 TCP 서버를 생성하려면 다음

public TcpServer() throws IOException {  
    // Create a TCP acceptor  
    IoAcceptor acceptor = new NioSocketAcceptor();  
  
    // Associate the acceptor to an IoHandler instance (your application)  
    acceptor.setHandler(this);  
  
    // Bind : this will start the server...  
    acceptor.bind(new InetSocketAddress(PORT));  
  
    System.out.println("Server started...");  
}

과 같은 코드를 작성하면 됩니다. 이렇게 하면 Tcp 서버가 생성됩니다. UDP 서버를 생성하려면 IoAcceptor acceptor = new NioDatagramAcceptor( );

해제하려면

acceptor.dispose(true)

를 호출하여 필터 체인을 추가하고

// Add a logger filter  
DefaultIoFilterChainBuilder chain = new DefaultIoFilterChainBuilder();  
chain.addLast("logger", new LoggingFilter());  
  
// And inject the created chain builder in the service  
acceptor.setFilterChainBuilder(chain);

서비스에 추가하면 됩니다. 위 내용은 Apache의 내용입니다. 미나 스터디노트(3) - IoService 관련 내용을 더 보시려면 PHP 중국어 홈페이지(m.sbmmt.com)를 팔로우해주세요!