本篇文章給大家分享的是有關(guān)怎么在Java中利用socket實(shí)現(xiàn)的客戶(hù)端和服務(wù)端通信功能完，小編覺(jué)得挺實(shí)用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說(shuō)，跟著小編一起來(lái)看看吧。

成都創(chuàng)新互聯(lián)公司-專(zhuān)業(yè)網(wǎng)站定制、快速模板網(wǎng)站建設(shè)、高性?xún)r(jià)比龍泉驛網(wǎng)站開(kāi)發(fā)、企業(yè)建站全套包干低至880元,成熟完善的模板庫(kù),直接使用。一站式龍泉驛網(wǎng)站制作公司更省心,省錢(qián),快速模板網(wǎng)站建設(shè)找我們，業(yè)務(wù)覆蓋龍泉驛地區(qū)。費(fèi)用合理售后完善，十余年實(shí)體公司更值得信賴(lài)。

客戶(hù)端實(shí)例

ChatClient.java

package socketDemo;
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
public class ChatClient extends Frame {
  Socket s = null;
  DataOutputStream dos = null;
  DataInputStream dis = null;
  private boolean bConnected = false;
  TextField tfTxt = new TextField();
  TextArea taContent = new TextArea();
  Thread tRecv = new Thread(new RecvThread());
  public static void main(String[] args) {
    new ChatClient().launchFrame();
  }
  public void launchFrame() {
    setLocation(400, 300);
    this.setSize(300, 300);
    add(tfTxt, BorderLayout.SOUTH);
    add(taContent, BorderLayout.NORTH);
    pack();
    this.addWindowListener(new WindowAdapter() {
      @Override
      public void windowClosing(WindowEvent arg0) {
        disconnect();
        System.exit(0);
      }
    });
    tfTxt.addActionListener(new TFListener());
    setVisible(true);
    connect();
    tRecv.start();
  }
  public void connect() {
    try {
      s = new Socket("localhost", 8888);
      dos = new DataOutputStream(s.getOutputStream());
      dis = new DataInputStream(s.getInputStream());
      System.out.println("connected!");
      bConnected = true;
    } catch (UnknownHostException e) {
      e.printStackTrace();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
  public void disconnect() {
    try {
      dos.close();
      dis.close();
      s.close();
    } catch (IOException e) {
      e.printStackTrace();
    }
    /*
     * try { bConnected = false; tRecv.join(); } catch(InterruptedException
     * e) { e.printStackTrace(); } finally { try { dos.close(); dis.close();
     * s.close(); } catch (IOException e) { e.printStackTrace(); } }
     */
  }
  private class TFListener implements ActionListener {
    public void actionPerformed(ActionEvent e) {
      String str = tfTxt.getText().trim();
      // taContent.setText(str);
      tfTxt.setText("");
      try {
        // System.out.println(s);
        dos.writeUTF(str);
        dos.flush();
        // dos.close();
      } catch (IOException e1) {
        e1.printStackTrace();
      }
    }
  }
  private class RecvThread implements Runnable {
    public void run() {
      try {
        while (bConnected) {
          String str = dis.readUTF();
          // System.out.println(str);
          taContent.setText(taContent.getText() + str + '\n');
        }
      } catch (SocketException e) {
        System.out.println("退出了，bye!");
      } catch (EOFException e) {
        System.out.println("推出了，bye - bye!");
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
  }
}

socket服務(wù)端代碼

ChatServer.java

package socketDemo;
import java.io.*;
import java.net.*;
import java.util.*;
public class ChatServer {
  boolean started = false;
  ServerSocket ss = null;
  List clients = new ArrayList();
  public static void main(String[] args) {
    new ChatServer().start();
  }
  public void start() {
    try {
      ss = new ServerSocket(8888);
      started = true;
    } catch (BindException e) {
      System.out.println("端口使用中....");
      System.out.println("請(qǐng)關(guān)掉相關(guān)程序并重新運(yùn)行 it = clients.iterator();
           * it.hasNext(); ) { Client c = it.next(); c.send(str); }
           */
          /*
           * Iterator it = clients.iterator();
           * while(it.hasNext()) { Client c = it.next(); c.send(str);
           * }
           */
        }
      } catch (EOFException e) {
        System.out.println("Client closed!");
      } catch (IOException e) {
        e.printStackTrace();
      } finally {
        try {
          if (dis != null)
            dis.close();
          if (dos != null)
            dos.close();
          if (s != null) {
            s.close();
            // s = null;
          }
        } catch (IOException e1) {
          e1.printStackTrace();
        }
      }
    }
  }
}

本機(jī)測(cè)試運(yùn)行結(jié)果：

關(guān)閉客戶(hù)端窗口后，提示信息如下：

以上就是怎么在Java中利用socket實(shí)現(xiàn)的客戶(hù)端和服務(wù)端通信功能完，小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘９ぷ鲿?huì)見(jiàn)到或用到的。希望你能通過(guò)這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。