Java開(kāi)發(fā)實(shí)現(xiàn)的Socket雙向通信功能示例

更新時(shí)間：2018年01月10日 11:01:56 作者：看看白云

這篇文章主要介紹了Java開(kāi)發(fā)實(shí)現(xiàn)的Socket雙向通信功能,結(jié)合實(shí)例形式分析了java基于socket實(shí)現(xiàn)的服務(wù)器端與客戶端雙向通信相關(guān)操作技巧,需要的朋友可以參考下

本文實(shí)例講述了Java開(kāi)發(fā)實(shí)現(xiàn)的Socket雙向通信功能。分享給大家供大家參考，具體如下：

服務(wù)端

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class Server_1 {
  public static void main(String[] args) {
    InputStreamReader isr;
    BufferedReader br;
    OutputStreamWriter osw;
    BufferedWriter bw;
    String str;
    Scanner in = new Scanner(System.in);
    try {
      ServerSocket server = new ServerSocket(4444);// 在本機(jī)的4444端口開(kāi)放Server
      Socket socket = server.accept();// 只要產(chǎn)生連接，socket便可以代表所連接的那個(gè)物體，同時(shí)這個(gè)server.accept()只有產(chǎn)生了連接才會(huì)進(jìn)行下一步操作。
      System.out.println(socket.getInetAddress());// 輸出連接者的IP。
      System.out.println("建立了一個(gè)連接！");
      while (true) {
        isr = new InputStreamReader(socket.getInputStream());
        br = new BufferedReader(isr);
        System.out.println(socket.getInetAddress() + ":" + br.readLine());
        osw = new OutputStreamWriter(socket.getOutputStream());
        bw = new BufferedWriter(osw);
        System.out.print("回復(fù):");
        str = in.nextLine();
        bw.write(str + "\n");
        bw.flush();
      }
    } catch (IOException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
  }
}

客服端

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class Client_1 {
  public static void main(String[] args) {
    InputStreamReader isr;
    BufferedReader br;
    OutputStreamWriter osw;
    BufferedWriter bw;
    String str;
    Scanner in = new Scanner(System.in);
    try {
      Socket socket = new Socket("localhost", 4444);
//     System.out.println(socket.getInetAddress());// 輸出連接者的IP。
      System.out.println("成功連接服務(wù)器");
      while (true) {
        osw = new OutputStreamWriter(socket.getOutputStream());
        bw = new BufferedWriter(osw);
        System.out.print("回復(fù):");
        str = in.nextLine();
        bw.write(str + "\n");
        bw.flush();
        isr = new InputStreamReader(socket.getInputStream());
        br = new BufferedReader(isr);
        System.out.println(socket.getInetAddress() + ":" + br.readLine());
      }
    } catch (IOException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
  }
}

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

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

您可能感興趣的文章: