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.創(chuàng)建服務(wù)器地址和端口號(hào)

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("我是客戶端，我從服務(wù)器接收的數(shù)據(jù)"+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.創(chuàng)建socket對(duì)象

ServerSocket ?serversocket=new ServerSocket(8888);

//2.調(diào)用accept（）方法，等待客戶端的連接

System.out.println("服務(wù)器即將啟動(dòng)");

// 計(jì)數(shù)器記錄有幾個(gè)客戶端進(jìn)行連接

int count=0;

Socket socket=null;

while(true){

socket=serversocket.accept();

// 啟動(dòng)一個(gè)線程

socketThread st1=new socketThread(socket);

st1.start();

count++;

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

InetAddress ia=socket.getInetAddress();

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

}

//3.獲取輸入流進(jìn)行信息交互

// 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("我是服務(wù)器，客戶端說 ? "+info);

//

//

// }

// socket.shutdownInput();

// OutputStream os1=socket.getOutputStream();

// PrintWriter pw1=new PrintWriter(os1);

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

// 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();

}

}

}