Java에서 소켓 프로그래밍의 예 공유(그림)

소켓은 우리에게 매우 실용적입니다. 아래는 본 연구에 대한 참고 사항입니다. 주로 예외 유형, 상호 작용 원리, 소켓, ServerSocket 및 멀티스레딩으로 구분됩니다. 실시간 애플리케이션이나 실시간 게임의 경우 HTTP 프로토콜이 우리의 요구를 충족하지 못하는 경우가 많습니다. 현재 Socket은 우리에게 매우 실용적입니다. 아래는 본 연구에 대한 참고 사항입니다. 주로 예외 유형, 상호 작용 원리, 소켓, ServerSocket 및 멀티스레딩 측면에서 설명됩니다.

예외 유형Socket의 내용을 이해하기 전에 먼저 관련된 몇 가지 예외 유형을 이해해야 합니다. 다음 네 가지 유형은 모두 IOException에서 상속되므로 대부분이 IOException을 직접 팝업할 수 있습니다.

UnkownHostException: 　　 호스트 이름 또는 IP 오류

ConnectException: 　　 서버가 연결을 거부했습니다. 서버가 시작되지 않았습니다. (큐 수를 초과하여 연결이 거부되었습니다.)

SocketTimeoutException: 　　 연결 시간이 초과되었습니다
BindException: 　　 소켓 객체 지정된 로컬 IP 주소 또는 포트에 바인딩할 수 없습니다

Interaction processSocket과 ServerSocket의 상호 작용은 아래 그림에서 자세하고 명확하게 설명되었다고 생각합니다.

Socket 생성자Socket()

Socket(InetAddress 주소, int 포트)에서 UnknownHostException, IOException

Socket(InetAddress 주소, int 포트, InetAddress localAddress, int localPort)번째 행IOException
소켓( String 호스트, int 포트)throws UnknownHostException, IOException
Socket(String Host, int port, InetAddress localAddress, int localPort)throws IOException


매개 변수가 없는 첫 번째 항목을 제외하고 다른 생성자는 서버 연결과 연결을 시도합니다. . 실패하면 IOException 오류가 발생합니다. 성공하면 Socket 객체가 반환됩니다.

InetAddress는 호스트를 기록하는 데 사용되는 클래스입니다. 정적 getHostByName(String msg)은 인스턴스를 반환할 수 있으며, 정적 메서드 getLocalHost()도 현재 호스트의 IP 주소를 가져와 인스턴스를 반환할 수 있습니다. Socket(String 호스트, int 포트, InetAddress localAddress, int localPort) 생성자의 매개 변수는 각각 대상 IP, 대상 포트, 바인딩된 로컬 IP 및 바인딩된 로컬 포트입니다.

Socket 메소드getInetAddress(); 원격 서버의 IP 주소

getPort(); 원격 서버의 포트

getLocalAddress() 로컬 클라이언트의 IP 주소
getLocalPort() 포트 로컬 클라이언트의
getInputStream() ;     입력 스트림 가져오기
getOutStream();     출력 스트림 가져오기

이러한 메서드 중에서 가장 중요한 메서드는 getInputStream() 및 getOutputStream()입니다.

Socket statusisClosed(); //연결이 닫혔는지 여부, 닫혀 있으면 true를 반환하고, 그렇지 않으면 false를 반환합니다.

isConnect(); 그렇지 않으면 false를 반환

isBound(); //소켓이 로컬 포트에 바인딩된 경우 true를 반환하고, 그렇지 않으면 false를 반환합니다.

소켓 상태가 연결되었는지 확인하려면 다음 명령문을 사용하는 것이 좋습니다. 판사.

boolean isConnection=socket.isConnected() && !socket.isClosed(); //현재 연결이 진행 중인지 확인

소켓을 반쯤 닫습니다우리는 알 수 없습니다 우리가 얻는 입력 스트림에는 무엇이 있습니까? 읽기를 완료하는 데 얼마나 걸립니까? 다음은 몇 가지 일반적인 방법입니다.

litz 사용자 정의 식별자(아래 예와 같이 "bye" 문자열을 수신하면 소켓을 닫습니다)
litz 읽기 길이를 알려줍니다(일부 사용자 정의 프로토콜, 첫 번째 읽기 길이를 나타내기 위해 몇 바이트가 고정되어 있습니다.)
lm 모든 데이터 읽기
lm close를 호출할 때 소켓이 닫히면 입력 및 출력 스트림을 닫습니다.

• 
  

ServerSocket 생성자

ServerSocket()throws IOException
ServerSocket(int port)throws IOException
ServerSocket(int port, int backlog)throws IOException
ServerSocket(int port, int backlog, InetAddress bindAddr)throws IOException

주의사항: 1. 포트 서버가 모니터링할 포트입니다. BindAddr 서버 바인딩 IP

2 . 특정 포트를 사용할 수 있는 권한이 없으면 BindException 오류가 발생합니다. 예를 들어 포트 1~1023은 관리자에게 바인딩 권한이 필요합니다.

3. 포트가 0으로 설정되면 시스템이 자동으로 포트를 할당합니다.

4. bindAddr用于绑定服务器IP，为什么会有这样的设置呢，譬如有些机器有多个网卡。

5. ServerSocket一旦绑定了监听端口，就无法更改。ServerSocket()可以实现在绑定端口前设置其他的参数。 

单线程的ServerSocket例子 

public void service(){
  while(true){
    Socket socket=null;
    try{
      socket=serverSocket.accept();//从连接队列中取出一个连接，如果没有则等待
      System.out.println("新增连接："+socket.getInetAddress()+":"+socket.getPort());
      ...//接收和发送数据
    }catch(IOException e){e.printStackTrace();}finally{
      try{
        if(socket!=null) socket.close();//与一个客户端通信结束后，要关闭Socket
      }catch(IOException e){e.printStackTrace();}
    }
  }
}

多线程的ServerSocket

多线程的好处不用多说，而且大多数的场景都是多线程的，无论是我们的即时类游戏还是IM，多线程的需求都是必须的。下面说说实现方式：

•  主线程会循环执行ServerSocket.accept()；

•  当拿到客户端连接请求的时候，就会将Socket对象传递给多线程，让多线程去执行具体的操作；

实现多线程的方法要么继承Thread类，要么实现Runnable接口。当然也可以使用线程池，但实现的本质都是差不多的。

这里举例：

下面代码为服务器的主线程。为每个客户分配一个工作线程：

public void service(){
  while(true){
    Socket socket=null;
    try{
      socket=serverSocket.accept();            //主线程获取客户端连接
      Thread workThread=new Thread(new Handler(socket));  //创建线程
      workThread.start();                  //启动线程
    }catch(Exception e){
      e.printStackTrace();
    }
  }
}

当然这里的重点在于如何实现Handler这个类。Handler需要实现Runnable接口： 

class Handler implements Runnable{
  private Socket socket;
  public Handler(Socket socket){
    this.socket=socket;
  }
  
  public void run(){
    try{
      System.out.println("新连接:"+socket.getInetAddress()+":"+socket.getPort());
      Thread.sleep(10000);
    }catch(Exception e){e.printStackTrace();}finally{
      try{
        System.out.println("关闭连接:"+socket.getInetAddress()+":"+socket.getPort());
        if(socket!=null)socket.close();
      }catch(IOException e){
        e.printStackTrace();
      }
    }
  }
}

当然是先多线程还有其它的方式，譬如线程池，或者JVM自带的线程池都可以。这里就不说明了。

위 내용은 Java에서 소켓 프로그래밍의 예 공유(그림)의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!