关于Socket的解析以及双方即时通讯的java实现方法

2019-11-26 12:52:12

字体：大中小

来源：转载

供稿：网友

在Java编程之中，我们通常都会接触到网络编程，那么不可避免地就会接触到Socket通信，下面我将对Socket进行简单的解析，并给出双方通讯的代码实现方案

首先我们来介绍一下整个Socket的通信过程

首先服务端先创建一个SocketServer，那么创建一个SocketServer需要我们指定端口号，如下

ServerSocket serverSocket=new ServerSocket(8888);

像上面这样我们就简单的开了一个端口号为8888的ServerSocket了

接下来我们需要去接收来自客户端的连接请求，也就是图中的Other Socket，我们可以利用SockerServer的accept方法来建立连接，并且这个方法会返回一个Socket，用于和Other Socker进行通信，简单来说，我们就是利用SockerServer来获取Socket，然后利用这个Socket和别人通信

接下来我们获取Socket的输入输出流，实现发送和接收信息，到此，我们已经知道两方进行Socket通信的基本思路了

接下来我们来看看关于ServerSocket以及Socket的一些关键方法

ServerSocket

首先我们看一下ServerSocket的构造方法，一共有4种：

1、无参的构造方法：

ServerSocket()，返回没有绑定端口号的ServerSocket实例
2、含一个参数的构造方法：

ServerSocket(int port)，返回绑定给定端口号的ServerSocket实例

3、含两个参数的构造方法：

ServerSocket(int port, int backlog)，返回绑定给定端口号的ServerSocket实例，并且设定同步队列（syns queue）的大小

4、含三个参数的构造方法：

ServerSocket(int port, int backlog, InetAddress bindAddr)，返回绑定给定端口号的ServerSocket实例，并且设定同步队列（syns queue）的大小以及绑定给定的IP地址

主要看它的一些方法：

accept()

这个方法监听连接，一旦连接就返回一个Socket用于通信，需要注意的是，该方法为阻塞方法，如果没有连接程序并不会继续执行下去

close()

关闭Socket，如果accept还在阻塞的话，就会抛出一个SocketException的异常

关于ServerSocket就不多加赘述了，我们来看一看Socket

Socket

构造方法依然存在多种，这里只给出一个较为典型的

Socket(String host, int port),第一个参数是主机的IP地址作为字符串传入，第二个参数为端口号

getInputStream(), getOutputStream()

获得Socket的输入输出流，我们可以利用BufferReader以及PrintWriter来对这两个流进行操作,如下：

  BufferReader reader = new BufferedReader(                  new InputStreamReader(socket.getInputStream()));  PrintWriter writer = new PrintWriter(                  new OutputStreamWriter(socket.getOutputStream()));

下面简单编写一个双方互相通信的java实现

首先是服务端

import java.io.*;import java.net.ServerSocket;import java.net.Socket;import java.util.Scanner;/*** Created by Mezereon on 2017/3/1.*/public class TCPServer { private Socket socket; private ServerSocket serverSocket; private BufferedReader reader; private PrintWriter writer; private Scanner scanner = new Scanner(System.in); //开启服务 public void run() throws IOException {     startTheSocket(); } public void startTheSocket() throws IOException {   serverSocket=new ServerSocket(18080); //打开18080端口等待连接   acceptTheSocket();//接受连接并且初始化Socket，reader，writer   openTheNewThreadToGetMessageFromClient();   while(true) {         getYourMessage();//获取键盘数据并作为输入   } } //接受连接并且初始化Socket，reader，writer private void acceptTheSocket() throws IOException {   socket=serverSocket.accept();//阻塞方法，用于接受Socket连接   System.out.println("Some one connect me ，it is "+socket.getLocalSocketAddress());//打印地址   System.out.println("It's port is "+socket.getPort());//打印端口号   reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));//获得输入流   writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));//获得输出流 } //扫描键盘并输入数据 private void getYourMessage() throws IOException {   String yourMessage = scanner.nextLine();   checkYourMessage(yourMessage);//检查发送给客户端的信息   writer.println(yourMessage);//发送信息   writer.flush();//flush方法用于清空缓冲区，注意的是如果不flush你的信息可能发不出去一直存留在缓冲区 } //用于检查是否退出 private void checkYourMessage(String yourMessage) throws IOException {   //关闭各种   if (yourMessage.equals("exit")) {     socket.close();     writer.close();     reader.close();     System.exit(0);   } } //开启一个新的线程来监听客户端发来的信息 private void openTheNewThreadToGetMessageFromClient() throws IOException {   //开启一个新的线程   new Thread(new Runnable() {     @Override     public void run() {       getTheMessageFromClient();     }   }).start(); } //不断循环来获取客户端发来的信息 private void getTheMessageFromClient() {   while(true) {     String messageFromClient = null;     try {       messageFromClient = reader.readLine();     } catch (IOException e) {       e.printStackTrace();     }     printTheMessage(messageFromClient);//打印客户端发来的信息   } } //打印客户端发来的信息 private void printTheMessage(String messageFromClient) {   if(messageFromClient!=null)     System.out.println("He say:"+messageFromClient); }    }

然后开始编写客户端：

import java.io.*;import java.net.Socket;import java.util.Scanner;/** * Created by Mezereon on 2017/2/27. */public class TCPClient {  private Socket socket;  private BufferedReader reader ;  private PrintWriter writer;  private Scanner scanner = new Scanner(System.in);  //开启Socket来连接  public void run() throws IOException{      startTheSocket();  }  //开始连接服务端  private void startTheSocket() throws IOException{      toConnectTheServer();//创建Socket并初始化      openTheThreadToReceiveInfoFromServer();//开启一个新的线程来接受服务端发来的信息      //一个循环，用于读取键盘的输入      while(true) {        String yourMessage = scanner.nextLine();        //不为空则发送信息        if(yourMessage!=null) {          writer.println(yourMessage);          writer.flush();//记得flush清空缓冲区        }        //判断是否退出        if (yourMessage.equals("exit")) {          disConnect();          System.exit(0);        }      }  }  //创建一个Socket来连接本机的18080端口的服务端并初始化reader和writer  private void toConnectTheServer() throws IOException {    socket=new Socket("127.0.0.1",18080);    reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));    writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()),true);  }  private void openTheThreadToReceiveInfoFromServer() throws IOException {    new Thread(new Runnable() {      @Override      public void run() {        try {          printMessage();//打印从服务端收到的信息        } catch (IOException e) {          e.printStackTrace();        }      }    }).start();  }  //循环不断读取服务端的信息  private void printMessage() throws IOException {    while (true) {      String messageFromServer = null;      try {        messageFromServer = reader.readLine();//读取信息        System.out.println("He say:" + messageFromServer);//打印信息      } catch (IOException e) {        e.printStackTrace();      } catch (NullPointerException e) {      }      if(messageFromServer.equals("exit")){        disConnect();//关闭连接        System.exit(0);      }    }  }  //关闭各种  private void disConnect() throws IOException {    socket.close();    reader.close();    writer.close();  }}

至此，关于Socket通信简单的介绍以及利用java进行简单的通信的实现就结束了~

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持武林网。

上一篇：Spring Boot 集成Mybatis实现主从（多数据源）分离方案示例

下一篇：Java编程基本概念