java socket接口
阿新 • • 發佈:2017-10-08
nec serve bsp ade 服務器 conn div 輸入流 oid PrintWriter write = new PrintWriter(socket.getOutputStream()); //獲取socket的輸出流
write.flush();//發送數據,刷新輸出流
InputStreamReader in =new new InputStreamReader(socket.getInputStream()); //獲取socket的輸入流
服務器端:
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter;import java.net.ServerSocket; import java.net.Socket; public class Service { ServerSocket server; Socket socket; public Service() { //建立服務器 try { server = new ServerSocket(10086); System.out.println("start service"); onServer(); } catch(IOException e) { System.out.print("failed to start service"); } } private void onServer() { try { socket = server.accept(); //監聽端口 BufferedReader in=new BufferedReader(new InputStreamReader(socket.getInputStream())); String line;//不斷從已建立鏈接的socket接收數據 do{ line = in.readLine(); System.out.println("Client Say:" + line); } while(!line.equals("quit")); in.close(); socket.close(); server.close(); } catch (IOException e) { System.out.println("Error" + e); } } public static void main(String[] args) { Service s = new Service(); } }
客戶端:
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; public class Client { private Socket socket; public Client() { //連接服務器 try { socket = new Socket("localhost",10086); HandleInput(); } catch (IOException e) { System.out.println("failed to connect Service"); } } private void HandleInput() { try { BufferedReader br = new BufferedReader(new InputStreamReader(System.in)); PrintWriter write = new PrintWriter(socket.getOutputStream()); String readline; do { readline = br.readLine(); write.println(readline); //寫入輸出端 write.flush();//刷新,發送 System.out.println(readline); } while (!readline.equals("quit!")); write.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } public static void main(String[] args) { Client c = new Client(); } }
java socket接口