黑馬程式員——基于TCP的區域網路聊天軟體

---------------------- android教育訓練、java教育訓練、期待與您交流！ ---------------------- 

這個簡單的功能，寫了好多次中間出現過很多問題，比如位元組流與字元流的轉換，比如如何把字元串轉換為位元組流傳輸等等。

  最後的模闆來源于畢老師講課的代碼。但是就此代碼還不能作為聊天軟體。因為它是用戶端發一個消息，然後就等待服務端接收消息并發送消息，在未接收到服務端消息之前，用戶端不能繼續發送消息。這樣不符合聊天軟體的需求。然後想了很多辦法，最後用多線程實作了這一功能。

代碼 服務端：

package com.net;
import java.io.*;
import java.net.*;

public class Test1 {
	public static void main(String[] args) throws IOException{
		
			ServerSocket ss=new ServerSocket(30000);
		
			Socket s=ss.accept();
			Test3 t=new Test3(s);
			t.start();
			
                       String ip=s.getInetAddress().getHostAddress();
System.out.println(ip);
			BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
			BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
			
			String line =null;
			
			while((line=br.readLine())!=null){
                               System.out.println(line);
                               
			}
			
			s.close();
			ss.close();
			
			
		
			
		}
		
		
		
	
	

}
           

package com.net;


import java.io.*;
import java.net.Socket;


import java.util.ArrayList;
import java.util.Scanner;


public class Test3 extends Thread{
Socket s=null;
BufferedWriter bw=null;
public Test3(Socket s) throws IOException{
this.s=s;
bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));

public void run(){
BufferedReader brin=new BufferedReader(new InputStreamReader(System.in));
try {
String line=null;
while((line=brin.readLine())!=null){
if(line.equals("exit")) break;
bw.write(line);
System.out.println("1111111'");
 bw.newLine();
bw.flush();
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

}






           

用戶端：

package com.net;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintStream;
import java.io.Reader;
import java.net.Socket;
import java.net.UnknownHostException;

public class Test2 {
	public static void main(String[] args) throws UnknownHostException, IOException{
		
		Socket s=new Socket("192.168.1.101",30000);
		Test4 t=new Test4(s);
		t.start();
		BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
		BufferedReader brin=new BufferedReader(new InputStreamReader(System.in));
		String line=null;
		while((line=brin.readLine())!=null){
			bw.write(line);
			bw.write(line);
            bw.newLine();
            bw.flush();
		}
		s.close();
		
		
		
		
	}

}
           

package com.net;

import java.io.*;
import java.net.Socket;

import java.util.ArrayList;
import java.util.Scanner;

public class Test4 extends Thread{
	Socket s=null;
	BufferedWriter bw=null;
	public Test4(Socket s) throws IOException{
		this.s=s;
		bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
		
		
	}
	public void run(){
		try {
			BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
			String line=null;
			while((line=br.readLine())!=null){
				System.out.println(line);
			}
			
			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	
	
	}
	
}


           

最後的效果，可以在一台用戶端與服務端之間自由聊天。未解決的問題：在多個用戶端之間實作聊天功能。

學到的知識：用BuffereWriter可以對字元流進行包裝，注意，是字元流，不是位元組流。

但是在readLine的時候要進行重新整理。

--------------------- android教育訓練、java教育訓練、期待與您交流！ ----------------------詳細請檢視：http://edu.csdn.net/heima