socketclient.java

java编写的一个网络象棋,通过对方ip连接,开始游戏,同时可以进行聊天,聊天部分通过线程实现,可以同时进行多个会话.

package net;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.util.StringTokenizer;

public class SocketClient{            //客户端
	
	private BufferedReader in;
	private PrintWriter out;
	private InetAddress addr;
	private Socket socket;

	public SocketClient(String ipStr)throws Exception{
		connect(ipStr);
	}

	public void connect(String ipStr) throws Exception{		
		byte []b=new byte[4];
		int  []c=new int[4];
		String []s=new String[4];
		StringTokenizer st=new StringTokenizer(ipStr,".");
		for(int i=0;i<4;i++){
			s[i]=st.nextToken();
			c[i]=Integer.valueOf(s[i]).intValue();
			b[i]=(byte)c[i];
		}
		
		addr = InetAddress.getByAddress(b);
		
		socket = new Socket(addr, Net.PORT);
		System.out.println(socket.toString());
		try{
			in = new BufferedReader(
						new InputStreamReader(
								socket.getInputStream()));
			out = new PrintWriter(
						new BufferedWriter(
								new OutputStreamWriter(
										socket.getOutputStream())), true);
			
			send("connect");
					
			System.out.println("客户端:");
										
		}catch(Exception e){
			System.out.println("异常...");
		}
		Net.isServer=false;
		Net.hasConnected=true;          //标记已连接
	}
	public void send(String message){
		System.out.println("    客户端发信息:"+message);
		out.println(message);
		out.flush();
	}
	public String read() throws Exception{
		String s=in.readLine();
		System.out.println("客户端收到: "+s);
		return s;
	}
}