controller.txt

本源码为五子棋源码 可以在java环境中运行

import java.io.*;
import java.net.*;
import javax.swing.*;

public class Controller extends JFrame {
	
	private static final long serialVersionUID = 1L;
	String address;
	int[] chess; 
	GamePanel panel, panelSec;
	ServerSocket ss = null;
	ObjectInputStream in ;
	ObjectOutputStream out;
	
	Controller() {
		chess = new int[3];
		panel = new GamePanel(this);
		add(panel);
		setSize(panel.getSize().width+4, panel.getSize().height+26);
		setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
		setVisible(true);
		
		gameServer();
	}

	// accept data from frame
	void chessIsDown(int x, int y, int color) {
		chess[0] = x;
		chess[1] = y;
		chess[2] = color;
		sendData(chess);
	}
	
	private void sendData(int[] chess) {
		try {
			out.writeObject(chess);
			
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	// put data of accept to frame 
	int[] acceptData() {
		try {
			chess = (int[])in.readObject();
			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return chess;
	}
	
	void linkTo(String str) {
		// 进入客户端模式
		address = str;
		gameClient();
	}
	
	//
	
	// 服务端模式
	private void gameServer() {
		
		//new ServerThread().start();
	}
	
	// 后台 - 服务端线程
	class ServerThread extends Thread {
		
		public void run() {
			Socket s = null;

			System.out.println("thread is run");
			try {
				ss = new ServerSocket(6969);
				if(!panel.gameIsRunning()) {
					
				    s = ss.accept();
				}
				// 提示: 一个用户请求连接
				//

				try {
					in = new ObjectInputStream(s.getInputStream());
					out = new ObjectOutputStream(s.getOutputStream());

				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				// 已建立连接, 开始游戏
				panel.isLink(s.getInetAddress().toString().substring(1));

			} catch (IOException e) {

			}
		}
	}
	
	// 客户端模式
	private void gameClient() {

		Socket sc = null;
		try {

			sc = new Socket(address, 6969);
			in = new ObjectInputStream(sc.getInputStream());
			out = new ObjectOutputStream(sc.getOutputStream());
			
		} catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		// 设为客户端
		panel.setClientModel();
		// 已建立连接, 开始游戏
		panel.isLink(sc.getInetAddress().toString().substring(1));
		
	}
	
	public static void main(String[] args) {
		new Controller();
	}
}