快捷導(dǎo)航

Java實(shí)現(xiàn)簡(jiǎn)單的socket通信教程

更新時(shí)間：2020年12月08日 10:49:42 作者：liushao

這篇文章主要介紹了Java實(shí)現(xiàn)簡(jiǎn)單的socket通信教程，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧

今天學(xué)習(xí)了一下java如何實(shí)現(xiàn)socket通信，感覺(jué)難點(diǎn)反而是在io上，因?yàn)閖ava對(duì)socket封裝已經(jīng)很完善了。

今天代碼花了整個(gè)晚上調(diào)試，主要原因是io的flush問(wèn)題和命令行下如何運(yùn)行具有package的類，不過(guò)最后問(wèn)題基本都解決了，把代碼貼出來(lái)供大家參考

server

public class TcpServer {
 public static void main(String[] args) throws Exception {
  ServerSocket server = new ServerSocket(9091);
  try {
   Socket client = server.accept();
   try {
    BufferedReader input =
      new BufferedReader(new InputStreamReader(client.getInputStream()));
    boolean flag = true;
    int count = 1;
 
    while (flag) {
     System.out.println(客戶端要開(kāi)始發(fā)騷了，這是第 + count + 次！);
     count++;
      
     String line = input.readLine();
     System.out.println(客戶端說(shuō)： + line);
      
     if (line.equals(exit)) {
      flag = false;
      System.out.println(客戶端不想玩了！);
     } else {
      System.out.println(客戶端說(shuō)： + line);
     }
 
    }
   } finally {
    client.close();
   }
    
  } finally {
   server.close();
  }
 }
}

client

public class TcpClient {
 public static void main(String[] args) throws Exception {
  Socket client = new Socket(127.0.0.1, 9091);
  try {
   PrintWriter output =
     new PrintWriter(client.getOutputStream(), true);
   Scanner cin = new Scanner(System.in);
   String words;
 
   while (cin.hasNext()) {
    words = cin.nextLine();
 
    output.println(words);
 
    System.out.println(寫(xiě)出了數(shù)據(jù): + words);
   }
 
   cin.close();
  } finally {
   client.close();
  }
 }
}

補(bǔ)充知識(shí)：Java-Socket通信同時(shí)JSON傳遞與解析

服務(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;
import net.sf.json.JSONObject;
public class Server_2 {
  public static void main(String[] args) {
    Scanner in=new Scanner(System.in);
    InputStreamReader isr;
    BufferedReader br;
    OutputStreamWriter osw;
    BufferedWriter rw;
    try {
      ServerSocket serverSocket=new ServerSocket(4444);
      Socket socket=serverSocket.accept();
      isr=new InputStreamReader(socket.getInputStream());
      br=new BufferedReader(isr);
      String str=br.readLine();
      JSONObject object=JSONObject.fromObject(str);
      System.out.println("ID:"+object.getInt("ID"));
      System.out.println("Name:"+object.getString("name"));
      System.out.println("password:"+object.getString("password"));
      br.close();
      socket.close();
      serverSocket.close();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
}

客服端

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.Scanner;
import net.sf.json.JSONObject;
public class Client_2 {
  public static void main(String[] args) {
    Scanner in = new Scanner(System.in);
    InputStreamReader isr;
    BufferedReader br;
    OutputStreamWriter osw;
    BufferedWriter rw;
    try {
      Socket socket = new Socket("localhost", 4444);
      osw = new OutputStreamWriter(socket.getOutputStream());
      rw = new BufferedWriter(osw);
      User user = new User();
      System.out.println("Id:");
      user.setID(in.nextInt());
      in.nextLine();
      System.out.println("Name:");
      user.setName(in.nextLine());
      System.out.println("Password:");
      user.setPassword(in.nextLine());
      JSONObject jsonObject = JSONObject.fromObject(user);
      rw.write(jsonObject.toString()+"\n");
      rw.close();
      socket.close();
    } catch (Exception e) {
      // TODO: handle exception
    }
  }
}

User

public class User {
  int ID;
  String name;
  String password;
  public int getID() {
    return ID;
  }
  public void setID(int iD) {
    ID = iD;
  }
  public String getName() {
    return name;
  }
  public void setName(String name) {
    this.name = name;
  }
  public String getPassword() {
    return password;
  }
  public void setPassword(String password) {
    this.password = password;
  }
}

以上這篇Java實(shí)現(xiàn)簡(jiǎn)單的socket通信教程就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: