package com.server;
?
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
?
import com.client.RunClient;
?
public class RunServer {
?? ?public static Socket socket=null;
?? ?/**
?? ? * 建立服務(wù)器被動連接
?? ? * @throws IOException
?? ? */
?? ?public void startServer() throws IOException {
?? ??? ?//服務(wù)器接收數(shù)據(jù)
?? ??? ?ServerSocket serverSocekt=new ServerSocket(8888);
?? ??? ?System.out.println("服務(wù)器啟動，等待連接...");
?? ??? ?//創(chuàng)建客戶端線程
?? ??? ?RunClient rc=new RunClient();
?? ??? ?Thread rct=new Thread(rc);
?? ??? ?rct.start();
?? ??? ?
?? ??? ?
?? ??? ?//阻塞線程 監(jiān)聽端口建立socket會話
?? ??? ?RunServer.socket=serverSocekt.accept();
?? ??? ?
?? ??? ?
?? ??? ?//獲取輸入留
?? ??? ?InputStream is=socket.getInputStream();
?? ??? ?//將字節(jié)輸入流轉(zhuǎn)換成字符輸入流
?? ??? ?InputStreamReader isr=new InputStreamReader(is);
?? ??? ?//將字符輸入流裝入帶緩沖的輸入流中
?? ??? ?BufferedReader br=new BufferedReader(isr);
?? ??? ?
?? ??? ?String str=null;
?? ??? ?while((str=br.readLine())!=null){
?? ??? ??? ?System.out.print("輸出信息："+str);
?? ??? ?}
?? ??? ?socket.shutdownInput();
?? ??? ?serverSocekt.close();
?? ?}
}

客戶端：

package com.client;
?
import java.io.BufferedWriter;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
?
import com.server.RunServer;
?
public class RunClient implements Runnable {
?? ?
?? ?@Override
?? ?public void run() {
?? ??? ?// TODO Auto-generated method stub
?? ??? ?Scanner input = new Scanner(System.in);
?? ??? ?System.out.println("1、主動連接\n2、被動等待");
?? ??? ?String sign=input.next();
?? ??? ?switch (sign) {
?? ??? ?case "1":
?? ??? ??? ?try {
?? ??? ??? ??? ?System.out.println("輸入服務(wù)器IP：");
?? ??? ??? ??? ?startClient(input.next());
?? ??? ??? ?} catch (Exception e) {
?? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ?}
?? ??? ??? ?break;
?? ??? ?case "2":
?? ??? ??? ?try {
?? ??? ??? ??? ?startClient();
?? ??? ??? ?} catch (Exception e) {
?? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ?}
?? ??? ??? ?break;
?? ??? ??? ?
?? ??? ?default:
?? ??? ??? ?break;
?? ??? ?}
?? ?}
?? ?
?? ?
?? ?/**
?? ? * 由已經(jīng)建立的socket 進(jìn)行連接反向連
?? ? * @throws Exception?
?? ? * @throws UnknownHostException?
?? ? */
?? ?public void startClient() throws Exception{
?? ??? ?
?? ??? ?while(true){
?? ??? ??? ?try {
?? ??? ??? ??? ?if(RunServer.socket!=null){
?? ??? ??? ??? ??? ?break;
?? ??? ??? ??? ?}
?? ??? ??? ??? ?Thread.sleep(1000);
?? ??? ??? ?} catch (InterruptedException e) {
?? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ?}
?? ??? ?}
?? ??? ?
?? ??? ?
?? ??? ?// 與服務(wù)器建立連接
?? ??? ?Socket socket=new Socket(RunServer.socket.getInetAddress().getHostAddress(), 8888);
?? ??? ?System.out.println("連接建立成功...");
?? ??? ?
?? ??? ?//向服務(wù)器寫入流
?? ??? ?OutputStream os=socket.getOutputStream();
?? ??? ?BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(os));
?? ??? ?Scanner input=new Scanner(System.in);
?? ??? ?
?? ??? ?while(true){
?? ??? ??? ?System.out.println("輸入信息：");
?? ??? ??? ?bw.write(input.next());
?? ??? ??? ?bw.newLine();
?? ??? ??? ?bw.flush();
?? ??? ?}
?? ?}
?? ?
?? ?/**
?? ? * 通過IP與服務(wù)器建立連接
?? ? * @throws Exception?
?? ? * @throws UnknownHostException?
?? ? */
?? ?public void startClient(String ip) throws Exception{
?? ??? ?// 與服務(wù)器建立連接
?? ??? ?Socket socket=new Socket(ip, 8888);
?? ??? ?System.out.println("連接建立成功...");
?? ??? ?
?? ??? ?//向服務(wù)器寫入流
?? ??? ?OutputStream os=socket.getOutputStream();
?? ??? ?BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(os));
?? ??? ?Scanner input=new Scanner(System.in);
?? ??? ?
?? ??? ?while(true){
?? ??? ??? ?bw.write(input.next());
?? ??? ??? ?bw.newLine();
?? ??? ??? ?bw.flush();
?? ??? ?}
?? ?}
}

main：

package com.start;
?
import com.server.RunServer;
?
public class Go {
?
?? ?public static void main(String[] args) throws Exception {
?? ??? ?// TODO Auto-generated method stub
?? ??? ?RunServer rs=new RunServer();
?? ??? ?rs.startServer();
?? ?}
?
}

效果：我是用虛擬機(jī)加本機(jī)