package java_socket;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

import java.net.UnknownHostException;

public class client {

public static void main(String[] args) ?{

//1.創建服務器地址和端口號

try {

Socket client1 = new Socket("localhost",8888);

OutputStream os1=client1.getOutputStream();

PrintWriter pw1=new PrintWriter(os1);

pw1.write("我是客戶端2");

pw1.flush();

client1.shutdownOutput();

InputStream is1=client1.getInputStream();

InputStreamReader isr=new InputStreamReader(is1);

BufferedReader br=new BufferedReader(isr);

String gain=null;

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

System.out.println("我是客戶端，我從服務器接收的數據"+gain);

}

client1.shutdownInput();

br.close();

isr.close();

is1.close();

pw1.close();

os1.close();

client1.close();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

package java_socket;

import java.io.BufferedInputStream;

import java.io.BufferedReader;

import java.io.FileInputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.io.PrintWriter;

import java.net.InetAddress;

import java.net.ServerSocket;

import java.net.Socket;

public class server {

public static void main(String[] args) {

try {

//1.創建socket對象

ServerSocket ?serversocket=new ServerSocket(8888);

//2.調用accept（）方法，等待客戶端的連接

System.out.println("服務器即將啟動");

// 計數器記錄有幾個客戶端進行連接

int count=0;

Socket socket=null;

while(true){

socket=serversocket.accept();

// 啟動一個線程

socketThread st1=new socketThread(socket);

st1.start();

count++;

System.out.println("我是服務器，客戶端連接 數量為"+count);

InetAddress ia=socket.getInetAddress();

System.out.println("當前客戶端的IP為"+ia.getHostAddress());

}

//3.獲取輸入流進行信息交互

// InputStream is1=socket.getInputStream();

// InputStreamReader isr1=new InputStreamReader(is1);

// BufferedReader bis1=new BufferedReader(isr1);

// String info =null;

// while((info=bis1.readLine())!=null){

// System.out.println("我是服務器，客戶端說 ? "+info);

//

//

// }

// socket.shutdownInput();

// OutputStream os1=socket.getOutputStream();

// PrintWriter pw1=new PrintWriter(os1);

// pw1.write("我是服務器，我說登錄成功");

// pw1.flush();

// socket.shutdownOutput();

// pw1.close();

// os1.close();

// bis1.close();

// isr1.close();

// is1.close();

// socket.close();

// serversocket.close();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}