欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java基于socket實現(xiàn)的客戶端和服務端通信功能完整實例

 更新時間:2018年05月23日 11:57:56   作者:愛代碼也愛生活  
這篇文章主要介紹了Java基于socket實現(xiàn)的客戶端和服務端通信功能,結(jié)合完整實例形式分析了Java使用socket建立客戶端與服務器端連接與通信功能,需要的朋友可以參考下

本文實例講述了Java基于socket實現(xiàn)的客戶端和服務端通信功能。分享給大家供大家參考,具體如下:

以下代碼參考馬士兵的聊天項目,先運行ChatServer.java實現(xiàn)端口監(jiān)聽,然后再運行ChatClient.java

客戶端實例

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服務端代碼

ChatServer.java

package socketDemo;
import java.io.*;
import java.net.*;
import java.util.*;
public class ChatServer {
  boolean started = false;
  ServerSocket ss = null;
  List<Client> clients = new ArrayList<Client>();
  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("請關(guān)掉相關(guān)程序并重新運行服務器!");
      System.exit(0);
    } catch (IOException e) {
      e.printStackTrace();
    }
    try {
      while (started) {
        Socket s = ss.accept();
        Client c = new Client(s);
        System.out.println("a client connected!");
        new Thread(c).start();
        clients.add(c);
        // dis.close();
      }
    } catch (IOException e) {
      e.printStackTrace();
    } finally {
      try {
        ss.close();
      } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
    }
  }
  class Client implements Runnable {
    private Socket s;
    private DataInputStream dis = null;
    private DataOutputStream dos = null;
    private boolean bConnected = false;
    public Client(Socket s) {
      this.s = s;
      try {
        dis = new DataInputStream(s.getInputStream());
        dos = new DataOutputStream(s.getOutputStream());
        bConnected = true;
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
    public void send(String str) {
      try {
        dos.writeUTF(str);
      } catch (IOException e) {
        clients.remove(this);
        System.out.println("對方退出了!我從List里面去掉了!");
        // e.printStackTrace();
      }
    }
    public void run() {
      try {
        while (bConnected) {
          String str = dis.readUTF();
          System.out.println(str);
          for (int i = 0; i < clients.size(); i++) {
            Client c = clients.get(i);
            c.send(str);
            // System.out.println(" a string send !");
          }
          /*
           * for(Iterator<Client> it = clients.iterator();
           * it.hasNext(); ) { Client c = it.next(); c.send(str); }
           */
          /*
           * Iterator<Client> 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();
        }
      }
    }
  }
}

本機測試運行結(jié)果:

關(guān)閉客戶端窗口后,提示信息如下:

更多關(guān)于java相關(guān)內(nèi)容感興趣的讀者可查看本站專題:《Java Socket編程技巧總結(jié)》、《Java文件與目錄操作技巧匯總》、《Java數(shù)據(jù)結(jié)構(gòu)與算法教程》、《Java操作DOM節(jié)點技巧總結(jié)》和《Java緩存操作技巧匯總

希望本文所述對大家java程序設(shè)計有所幫助。

相關(guān)文章

  • Java 如何實現(xiàn)AES加密

    Java 如何實現(xiàn)AES加密

    這篇文章主要介紹了Java 如何實現(xiàn)AES加密,幫助大家完成對接,完成自身需求,感興趣的朋友可以了解下
    2020-10-10
  • Java RMI引起的log4j漏洞問題重現(xiàn)

    Java RMI引起的log4j漏洞問題重現(xiàn)

    java的log4j框架出現(xiàn)了一個大漏洞對服務器案例引起了不小的影響,如果你使用的是spring框架,用的是logback,不受這個問題的影響,下面跟著小編看下Java RMI引起的log4j漏洞問題重現(xiàn),感興趣的朋友一起看看吧
    2021-12-12
  • JAVA設(shè)計模式之解釋器模式詳解

    JAVA設(shè)計模式之解釋器模式詳解

    這篇文章主要介紹了JAVA設(shè)計模式之解釋器模式詳解,解釋器模式是類的行為模式,給定一個語言之后,解釋器模式可以定義出其文法的一種表示,并同時提供一個解釋器,需要的朋友可以參考下
    2015-04-04
  • Mybatis-Spring連接mysql 8.0配置步驟出錯的解決方法

    Mybatis-Spring連接mysql 8.0配置步驟出錯的解決方法

    這篇文章主要為大家詳細介紹了Mybatis-Spring連接mysql 8.0配置步驟出錯的解決方法,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2019-06-06
  • Linux下用java -jar運行可執(zhí)行jar包的方法教程

    Linux下用java -jar運行可執(zhí)行jar包的方法教程

    這篇文章主要給大家介紹了在Linux下用java -jar運行可執(zhí)行jar包的方法教程,文中介紹的非常詳細,相信對大家的工作或者學習具有一定的參考學習價值,需要的朋友們下面來一起看看吧。
    2017-05-05
  • java讀取xml配置參數(shù)代碼實例

    java讀取xml配置參數(shù)代碼實例

    這篇文章主要介紹了java讀取xml配置參數(shù)代碼實例,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2019-12-12
  • IntelliJ IDEA設(shè)置Tabs實現(xiàn)同時打開多個文件且分行顯示

    IntelliJ IDEA設(shè)置Tabs實現(xiàn)同時打開多個文件且分行顯示

    今天小編就為大家分享一篇關(guān)于IntelliJ IDEA設(shè)置Tabs實現(xiàn)同時打開多個文件且分行顯示,小編覺得內(nèi)容挺不錯的,現(xiàn)在分享給大家,具有很好的參考價值,需要的朋友一起跟隨小編來看看吧
    2018-10-10
  • java創(chuàng)建子類對象設(shè)置并調(diào)用父類的變量操作

    java創(chuàng)建子類對象設(shè)置并調(diào)用父類的變量操作

    這篇文章主要介紹了java創(chuàng)建子類對象設(shè)置并調(diào)用父類的變量操作,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2021-01-01
  • 詳解spring Boot Cli的配置和使用

    詳解spring Boot Cli的配置和使用

    本篇文章主要介紹了詳解spring Boot Cli的配置和使用,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-05-05
  • Nacos?Client的Bug解決方法記錄

    Nacos?Client的Bug解決方法記錄

    這篇文章主要為大家介紹了Nacos?Client的Bug解決方法記錄,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-08-08

最新評論