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

java實現(xiàn)socket客戶端連接服務(wù)端

 更新時間:2015年10月08日 11:09:33   投稿:hebedich  
本文是個人剛剛開始學(xué)習(xí)如何通過socket去發(fā)送信息下邊的案例,也是書上的在這留下筆記,最后附上一個實例,有需要的小伙伴可以參考下。

本例只做簡單功能演示,代碼并不嚴(yán)謹(jǐn),只是說明客戶端如何實現(xiàn)連接服務(wù)端簡單代碼。

代碼在集成Eclipse工具下測試編譯運行環(huán)境如下圖所示:

客戶端echoClient.java代碼:

package com.zhengzz.echo;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

class EchoC{
  
  private Socket socket;
  
  public EchoC() {
    // TODO Auto-generated constructor stub
    try {
      socket = new Socket("localhost", 60000);
    } catch (UnknownHostException e) {
      e.printStackTrace();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
  
  public void Client() {
    try {
      BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
      PrintWriter pw = new PrintWriter(socket.getOutputStream(), true);
      BufferedReader lbr = new BufferedReader(new InputStreamReader(System.in));
      
      String linestr = null;
      while ((linestr = lbr.readLine()) != null) {
        
        pw.println(linestr);
        
        System.out.println(br.readLine());
        
        if (linestr.equals("bye#")) {
          break;
        }
      }
      
      
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
}

public class echoClient {

  public static void main(String[] args) {
    new EchoC().Client();
  }

}

服務(wù)端echoServer.java代碼:

package com.zhengzz.echo;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

class EchoS{
  
  private ServerSocket serverSocket;
  
  public EchoS() {
    
    try {
      serverSocket = new ServerSocket(60000);
    } catch (IOException e) {
      e.printStackTrace();
    }
    
  }
  
  public void Server() {
    while (true) {
      try {
        Socket socket = serverSocket.accept();
        
        System.out.println("client:" + socket.getInetAddress() + ":" + socket.getLocalPort());

        BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        PrintWriter pw = new PrintWriter(socket.getOutputStream(), true);

        String linestr;

        while ((linestr = br.readLine()) != null) {

          System.out.println(linestr);

          pw.println("--->" + linestr);

        }
      } catch (IOException e) {
        System.out.println("連接斷開:(");
      }

    }
}
}

public class echoServer {

  public static void main(String[] args) {
    new EchoS().Server();
  }

}

我在Eclipse工具下直接調(diào)試結(jié)果如下:

下面我們再來看一個 HelloWord 級別的 Java Socket 通信的例子。通訊過程:

        先啟動 Server 端,進入一個死循環(huán)以便一直監(jiān)聽某端口是否有連接請求。然后運行 Client 端,客戶端發(fā)出連接請求,服務(wù)端監(jiān)聽到這次請求后向客戶端發(fā)回接受消息,連接建立,啟動一個線程去處理這次請求,然后繼續(xù)死循環(huán)監(jiān)聽其他請求。客戶端輸入字符串后按回車鍵,向服務(wù)器發(fā)送數(shù)據(jù)。服務(wù)器讀取數(shù)據(jù)后回復(fù)客戶端數(shù)據(jù)。這次請求處理完畢,啟動的線程消亡。如果客戶端接收到 "OK" 之外的返回數(shù)據(jù),會再次發(fā)送連接請求并發(fā)送數(shù)據(jù),服務(wù)器會為這次連接再次啟動一個線程來進行響應(yīng)。。。直到當(dāng)客戶端接收到的返回數(shù)據(jù)為 "OK" 時,客戶端退出。

        服務(wù)端源代碼:

package com.defonds.socket.begin; 
 
import java.io.BufferedReader; 
import java.io.DataInputStream; 
import java.io.DataOutputStream; 
import java.io.InputStreamReader; 
import java.net.ServerSocket; 
import java.net.Socket; 
 
public class Server { 
  public static final int PORT = 12345;//監(jiān)聽的端口號   
   
  public static void main(String[] args) {  
    System.out.println("服務(wù)器啟動...\n");  
    Server server = new Server();  
    server.init();  
  }  
  
  public void init() {  
    try {  
      ServerSocket serverSocket = new ServerSocket(PORT);  
      while (true) {  
        // 一旦有堵塞, 則表示服務(wù)器與客戶端獲得了連接  
        Socket client = serverSocket.accept();  
        // 處理這次連接  
        new HandlerThread(client);  
      }  
    } catch (Exception e) {  
      System.out.println("服務(wù)器異常: " + e.getMessage());  
    }  
  }  
  
  private class HandlerThread implements Runnable {  
    private Socket socket;  
    public HandlerThread(Socket client) {  
      socket = client;  
      new Thread(this).start();  
    }  
  
    public void run() {  
      try {  
        // 讀取客戶端數(shù)據(jù)  
        DataInputStream input = new DataInputStream(socket.getInputStream()); 
        String clientInputStr = input.readUTF();//這里要注意和客戶端輸出流的寫方法對應(yīng),否則會拋 EOFException 
        // 處理客戶端數(shù)據(jù)  
        System.out.println("客戶端發(fā)過來的內(nèi)容:" + clientInputStr);  
  
        // 向客戶端回復(fù)信息  
        DataOutputStream out = new DataOutputStream(socket.getOutputStream());  
        System.out.print("請輸入:\t");  
        // 發(fā)送鍵盤輸入的一行  
        String s = new BufferedReader(new InputStreamReader(System.in)).readLine();  
        out.writeUTF(s);  
         
        out.close();  
        input.close();  
      } catch (Exception e) {  
        System.out.println("服務(wù)器 run 異常: " + e.getMessage());  
      } finally {  
        if (socket != null) {  
          try {  
            socket.close();  
          } catch (Exception e) {  
            socket = null;  
            System.out.println("服務(wù)端 finally 異常:" + e.getMessage());  
          }  
        }  
      }  
    }  
  }  
}  

客戶端源代碼:

package com.defonds.socket.begin; 
 
import java.io.BufferedReader; 
import java.io.DataInputStream; 
import java.io.DataOutputStream; 
import java.io.IOException; 
import java.io.InputStreamReader; 
import java.net.Socket; 
 
public class Client { 
  public static final String IP_ADDR = "localhost";//服務(wù)器地址  
  public static final int PORT = 12345;//服務(wù)器端口號  
   
  public static void main(String[] args) {  
    System.out.println("客戶端啟動...");  
    System.out.println("當(dāng)接收到服務(wù)器端字符為 \"OK\" 的時候, 客戶端將終止\n");  
    while (true) {  
      Socket socket = null; 
      try { 
        //創(chuàng)建一個流套接字并將其連接到指定主機上的指定端口號 
        socket = new Socket(IP_ADDR, PORT);  
          
        //讀取服務(wù)器端數(shù)據(jù)  
        DataInputStream input = new DataInputStream(socket.getInputStream());  
        //向服務(wù)器端發(fā)送數(shù)據(jù)  
        DataOutputStream out = new DataOutputStream(socket.getOutputStream());  
        System.out.print("請輸入: \t");  
        String str = new BufferedReader(new InputStreamReader(System.in)).readLine();  
        out.writeUTF(str);  
          
        String ret = input.readUTF();   
        System.out.println("服務(wù)器端返回過來的是: " + ret);  
        // 如接收到 "OK" 則斷開連接  
        if ("OK".equals(ret)) {  
          System.out.println("客戶端將關(guān)閉連接");  
          Thread.sleep(500);  
          break;  
        }  
         
        out.close(); 
        input.close(); 
      } catch (Exception e) { 
        System.out.println("客戶端異常:" + e.getMessage());  
      } finally { 
        if (socket != null) { 
          try { 
            socket.close(); 
          } catch (IOException e) { 
            socket = null;  
            System.out.println("客戶端 finally 異常:" + e.getMessage());  
          } 
        } 
      } 
    }  
  }  
}  

        注意: Socket 輸出流寫數(shù)據(jù)方法是 writeUTF 時,輸入流讀取相關(guān)數(shù)據(jù)要用 readUTF。否則會拋 EOFException 異常。

相關(guān)文章

  • MybatisPlus搭建項目環(huán)境及分頁插件

    MybatisPlus搭建項目環(huán)境及分頁插件

    Mybatis-Plus(簡稱MP)是一個Mybatis的增強工具,在Mybatis的基礎(chǔ)上只做增強不做改變,為簡化開發(fā)、提高效率而生,下面這篇文章主要給大家介紹了關(guān)于MybatisPlus搭建項目環(huán)境及分頁插件的相關(guān)資料,需要的朋友可以參考下
    2022-11-11
  • 教你使用java實現(xiàn)去除各種空格

    教你使用java實現(xiàn)去除各種空格

    本文給大家匯總介紹了5種java中去除空格的方法,分別是String.trim()、str.replace(" ", "");、replaceAll(" +","");以及自定義的remove函數(shù),非常的簡單實用,需要的小伙伴可以參考下。
    2015-03-03
  • 看完這篇文章獲得一些java if優(yōu)化技巧

    看完這篇文章獲得一些java if優(yōu)化技巧

    if 是每個語言都有的語法,也是最基礎(chǔ)的語法。因為代碼本來就很晦澀,所以才有了程序員這個中間件,今天就聊一下我的一些關(guān)于 if 思路和總結(jié)
    2021-07-07
  • spring boot + mybatis如何實現(xiàn)數(shù)據(jù)庫的讀寫分離

    spring boot + mybatis如何實現(xiàn)數(shù)據(jù)庫的讀寫分離

    這篇文章主要給大家介紹了關(guān)于spring boot + mybatis如何實現(xiàn)數(shù)據(jù)庫的讀寫分離的相關(guān)資料,文中通過示例代碼介紹的非常詳細,對大家學(xué)習(xí)或者使用spring boot具有一定的參考學(xué)習(xí)價值,需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧
    2019-09-09
  • 理解java多線程中ExecutorService使用

    理解java多線程中ExecutorService使用

    這篇文章主要幫助大家理解java多線程中ExcetorServiced的使用方法,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2016-12-12
  • SSH框架網(wǎng)上商城項目第29戰(zhàn)之使用JsChart技術(shù)顯示商品銷售報表

    SSH框架網(wǎng)上商城項目第29戰(zhàn)之使用JsChart技術(shù)顯示商品銷售報表

    這篇文章主要為大家詳細介紹了SSH框架網(wǎng)上商城項目第29戰(zhàn)之使用JsChart技術(shù)顯示商品銷售報表,感興趣的小伙伴們可以參考一下
    2016-06-06
  • 基于mybatis注解動態(tài)sql中foreach工具的方法

    基于mybatis注解動態(tài)sql中foreach工具的方法

    這篇文章主要介紹了mybatis注解動態(tài)sql中foreach工具方法,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-11-11
  • 新手初學(xué)Java流程控制

    新手初學(xué)Java流程控制

    這篇文章主要介紹了JAVA流程控制語句的的相關(guān)資料,文中講解非常細致,代碼幫助大家更好的理解和學(xué)習(xí),感興趣的朋友可以了解下,希望可以幫到你
    2021-07-07
  • java中Timer定時器的使用和啟動方式

    java中Timer定時器的使用和啟動方式

    這篇文章主要介紹了java中Timer定時器的使用和啟動方式,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-12-12
  • Java中抓取 Thread Dumps 的方式匯總

    Java中抓取 Thread Dumps 的方式匯總

    Thread dumps(線程轉(zhuǎn)儲)能幫助我們判斷 CPU 峰值、死鎖、內(nèi)存異常、應(yīng)用反應(yīng)遲鈍、響應(yīng)時間變長和其他系統(tǒng)問題。在這篇文章當(dāng)中,總結(jié)了7中抓取 Java Thread Dumps 文件的方式,分享給大家,希望對大家學(xué)習(xí)Java能夠有所幫助。
    2016-06-06

最新評論