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

在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进行简单的通信的实现就结束了~

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

# java  # socket  # 通讯  # socket即时通讯  # 双方通讯  # Java的Socket通讯基础编程完全指南  # Android 模拟器(JAVA)与C++ socket 通讯 分享  # 基于Java语言实现Socket通信的实例  # java使用MulticastSocket实现组播  # java使用MulticastSocket实现基于广播的多人聊天室  # java+jdbc+mysql+socket搭建局域网聊天室  # java 实现websocket的两种方式实例详解  # java socket实现聊天室 java实现多人聊天功能  # Java socket通讯实现过程及问题解决  # 端口号  # 服务端  # 客户端  # 绑定  # 的是  # 就会  # 创建一个  # 可以利用  # 接触到  # 清空  # 流进  # 还在  # 第一个  # 就不  # 开了  # 这两个  # 第二个  # 如果没有  # 来看看  # 将对 

相关文章： 广州网站制作公司哪家好一点,广州欧莱雅百库网络科技有限公司官网？  完全自定义免费建站平台：主题模板在线生成一站式服务  建站之星如何快速解决建站难题？  如何高效配置IIS服务器搭建网站？  建站主机是什么？如何选择适合的建站主机？  如何在Mac上搭建Golang开发环境_使用Homebrew安装和管理Go版本  建站之星IIS配置教程：代码生成技巧与站点搭建指南  大连企业网站制作公司,大连2025企业社保缴费网上缴费流程？  实惠建站价格推荐：2025年高性价比自助建站套餐解析  建站IDE高效指南：快速搭建+SEO优化+自适应模板全解析  昆明高端网站制作公司,昆明公租房申请网上登录入口？  建站之星展会模板：智能建站与自助搭建高效解决方案  公众号网站制作网页,微信公众号怎么制作？  如何快速生成橙子建站落地页链接？  沈阳个人网站制作公司,哪个网站能考到沈阳事业编招聘的信息？  c# 在高并发场景下，委托和接口调用的性能对比  高防服务器租用首荐平台，企业级优惠套餐快速部署  怎么用手机制作网站链接,dw怎么把手机适应页面变成网页？  如何选择高效响应式自助建站源码系统？  定制建站方案优化指南：企业官网开发与建站费用解析  建站之星体验版：智能建站系统+响应式设计，多端适配快速建站  如何在宝塔面板创建新站点？  微网站制作教程,我微信里的网站怎么才能复制到浏览器里？  在线ppt制作网站有哪些软件,如何把网页的内容做成ppt？  建站主机选择指南：服务器配置与SEO优化实战技巧  建站之星客服服务时间及联系方式如何？  Swift开发中switch语句值绑定模式  如何在阿里云香港服务器快速搭建网站？  如何在橙子建站中快速调整背景颜色？  ,有什么在线背英语单词效率比较高的网站？  怀化网站制作公司,怀化新生儿上户网上办理流程？  教程网站设计制作软件,怎么创建自己的一个网站？  Swift中循环语句中的转移语句 break 和 continue  建站之星CMS五站合一模板配置与SEO优化指南  5种Android数据存储方式汇总  制作销售网站教学视频,销售网站有哪些？  网站网页制作电话怎么打,怎样安装和使用钉钉软件免费打电话？  如何快速搭建高效WAP手机网站吸引移动用户？  临沂网站制作企业,临沂第三中学官方网站？  如何在阿里云服务器自主搭建网站？  阿里云网站搭建费用解析：服务器价格与建站成本优化指南  网站制作的步骤包括,正确网址格式怎么写？  ,怎么用自己头像做动态表情包？  制作ppt免费网站有哪些,有哪些比较好的ppt模板下载网站？  如何打造高效商业网站？建站目的决定转化率  如何选择网络建站服务器？高效建站必看指南  公司门户网站制作公司有哪些,怎样使用wordpress制作一个企业网站？  百度网页制作网站有哪些,谁能告诉我百度网站是怎么联系？  网站制作软件免费下载安装,有哪些免费下载的软件网站？  青岛网站设计制作公司,查询青岛招聘信息的网站有哪些？