五子棋人机对战java,java五子棋网络对战

　　做完java单机五子棋，开始尝试写网络五子棋(在局域网，因为没有公开IP)。上次五子棋写的很乱，都是一个班写的。这一次，我使用了面向对象的思想，将特定的函数和属性编写到一个类中。代码分为两部分，客户端和服务器端。客户端用AWT编写，主要由五子棋面板和功能键面板组成。网络使用TCP，通过序列化和反序列化来读写消息。运行时，先运行服务器程序，再运行两个客户端。代码放在文章的末尾。

　　下面是客户端运行的效果：

　　下面是代码包的结构：

　　然后我再依次说说这几个类的作用。

　　Media包

　　媒体包：主要包括五子棋的背景图片、播放音乐的类别以及音乐内容。

　　我是跟室友上的音乐演奏课，所以不太懂。我扫了一眼，是用Applet做的，只能用处理音乐。wav后缀。

　　Net包

　　Net:它包含两个类。细心的朋友要注意，客户端没有main方法。客户端实际上包含了与服务器通信的套接字，其中包含了一些读写方法。我在服务器端使用线程池的方法来处理客户端的请求(我对线程池不是很了解，类似于多线程)。

　　View包

　　套装：包含四个类，即棋盘，棋盘，棋子和谁查看。

　　棋盘是一个包含主方法的JFrame，命令面板和棋盘面板都被添加到这个JFrame中。

　　ChessPanel是一个棋盘面板，完成绘制19*19棋盘线、加载背景图片、不断接收和处理来自服务器的消息(给面板添加棋子)、给面板添加棋子和每次点击后给服务器发送棋子、判断胜负并给出提示消息等任务。

　　棋子是棋子，包含颜色、棋子半径、棋子位置、命令等属性(与前面的命令面板配合使用，默认为发送)。

　　谁是五子棋中判断谁胜谁负的那一部分。每一步都需要判断。

　　播放音乐的类：

　　包装媒体。音乐；导入Java . io . file；导入Java . io . io exception；导入javax . sound . sampled . audio inputstream；导入javax . sound . sampled . audio system；导入javax . sound . sampled . clip；导入javax . sound . sampled . lineunavailableexception；import javax . sound . sampled . unsupportdaudiofileexception；公开课PlayMusic { private Clip clippublic PlayMusic(String filePath)抛出LineUnavailableException，UnsupportedAudioFileException，io exception { File File=new File(File path)；audio inputstream audio inputstream=audio system . getaudioinputstream(file)；clip=audio system . get clip()；clip . open(audio inputstream)；} public void play(){ clip . setframeposition(1)；clip . start()；} public void loop(){ Clip . loop(Clip。循环_连续)；} public void stop(){ clip . stop()；}}TcpClient:

　　包网；导入视图。件；导入Java . io . *；导入Java . net . socket；公共类TcpClient { private Socket socket私有ObjectInputStream ois私有ObjectOutputStream oospublic TcpClient(Socket socket，ObjectInputStream ois，ObjectOutputStream OOS){ this . Socket=Socket；this.ois=ois这

　　.oos = oos; } public Socket getSocket() { return socket; } public void setSocket(Socket socket) { this.socket = socket; } public ObjectInputStream getOis() { return ois; } public void setOis(ObjectInputStream ois) { this.ois = ois; } public ObjectOutputStream getOos() { return oos; } public void setOos(ObjectOutputStream oos) { this.oos = oos; } public void send(Pieces pieces) throws IOException { oos.writeObject(pieces); System.out.println(socket+"向服务器发送消息"); } public Pieces accept() throws IOException, ClassNotFoundException { Pieces pieces = (Pieces) ois.readObject(); System.out.println(socket+"从服务器读取消息"); return pieces; } public void close(){ ; }}TcpServer:

package net;import view.Pieces;import java.io.*;import java.net.ServerSocket;import java.net.Socket;import java.net.SocketException;import java.util.ArrayList;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;public class TcpServer {    public static void main(String[] args) {        // 保存客户端处理的线程        ArrayList<UserThread> userList = new ArrayList<>();        // 固定大小的线程池只支持两个线程，用来处理客户端        ExecutorService es = Executors.newFixedThreadPool(2);        try {            ServerSocket server = new ServerSocket(10086);            System.out.println("服务器已经启动，正在等待客户端连接......");            while (true) {                //接收客户端的Socket，如果没有客户端连接就一直卡在这里                Socket socket = server.accept();                // 每来一个用户就创建一个线程                UserThread user = new UserThread(socket, userList);                // 开启线程                es.execute(user);            }        } catch (IOException e) {            e.printStackTrace();        }    }} class UserThread implements Runnable {    private Socket socket = null;    private static ArrayList<UserThread> list; // 客户端线程集合    private ObjectOutputStream oos;    private ObjectInputStream ois;    private boolean flag = true;// 标记     public UserThread(Socket socket, ArrayList<UserThread> list) {        this.socket = socket;        this.list = list;        list.add(this); // 把当前线程加入list中    }     @Override    public void run() {        UserThread user = null;        try {            System.out.println("客户端:" + socket.getInetAddress().getHostAddress() + "已经连接");            ois = new ObjectInputStream(socket.getInputStream());            oos = new ObjectOutputStream(socket.getOutputStream());            while(true){                Pieces pieces = (Pieces) ois.readObject(); // 客户端发给服务端的消息，把他写到其它套接字中去                int size = list.size();                for (int i = 0; i < size; i++) {                    user = list.get(i);                    if (user.socket != socket) {                        user.oos.writeObject(pieces);                        System.out.println("从"+socket+"向"+user.socket+"发送消息");                    }                }            }        } catch(SocketException e){ //  todo 客户端掉线后，移除客户端。没想好{1.从客户端列表移除当前元素，关闭当前：socket，通知另一方：这一方已经掉线，然后关闭这一方的socket}            try {                int i = list.size();                if (i ==2){                    list.remove(user);                    System.out.println("已经删除了一个客户端");                    list.get(0).oos.writeObject(new Pieces("对方掉线"));                }else if (i==1){                    list.remove(0);                    System.out.println("又移除了另一个客户端");                }            } catch (IOException ex) {                ex.printStackTrace();            }        } catch (IOException e) {            e.printStackTrace();        } catch (ClassNotFoundException e) {            e.printStackTrace();        }    }}

ChessBoard:

/** 1.变量值不变的问题* 2.输入输出流先后顺序的问题（socket阻塞）* 3.socket 短连接不关闭输入输出流，为何看起来就像长连接一样（长短连接的区别是什么）* */// todo 一个提示框package view;import Media.Music.PlayMusic;import javax.sound.sampled.LineUnavailableException;import javax.sound.sampled.UnsupportedAudioFileException;import javax.swing.*;import java.awt.*;import java.awt.event.ActionEvent;import java.awt.event.ActionListener;import java.io.IOException;public class ChessBoard extends JFrame implements ActionListener {    private JButton PlayMusic = new JButton("播放音乐");    private ChessPanel chessPanel;    private Panel CommandPanel = new Panel();    private JButton reStart = new JButton("重新开始");    private JButton fail = new JButton("认输");    private JButton Regret = new JButton("悔棋");    private String command=null; // 触发按钮后发送的命令    private PlayMusic music = null;    private int count = 1;    //  todo 静态语句块    {        try {            music = new PlayMusic("./src/Media/Music/bg3.wav");        } catch (LineUnavailableException e) {            e.printStackTrace();        } catch (UnsupportedAudioFileException e) {            e.printStackTrace();        } catch (IOException e) {            e.printStackTrace();        }    }     public ChessBoard() {        this.setTitle("欢乐五子棋");        chessPanel = new ChessPanel();        this.add(chessPanel,BorderLayout.CENTER);        reStart.addActionListener(this);        fail .addActionListener(this);        Regret.addActionListener(this);        PlayMusic.addActionListener(this);        CommandPanel.add(reStart);        CommandPanel.add(fail);        CommandPanel.add(Regret);        CommandPanel.add(PlayMusic);        this.add(CommandPanel,BorderLayout.SOUTH);        this.setBounds(10, 10, 800, 800);        this.setVisible(true);        this.setResizable(false);        this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);    }    public static void main(String[] args) {        ChessBoard Board = new ChessBoard();     }    @Override    public void actionPerformed(ActionEvent e) {        if(e.getSource()==reStart){            command ="重新开始";            chessPanel.canPlay = true;        }else if(e.getSource()==fail){            command ="认输";            JOptionPane.showMessageDialog(chessPanel,"Its a pity,you have fail the game!");            chessPanel.canPlay = false;        }else if (e.getSource()==Regret){            command ="悔棋";        }else if (e.getSource()==PlayMusic){            // todo 播放音乐,单数次播放；            if (count%2==1){                music.play();            }else {                music.stop();            }            count++;            command = null;        }        if(command!=null){            Pieces pieces = new Pieces(command);            try {                this.chessPanel.client.send(pieces);            } catch (IOException ex) {                ex.printStackTrace();            }        }     }}

ChessPanel:

package view;// 五子棋面板，就是在这里面画图。// todo 背景图片 ，也许一个背景音乐import net.TcpClient;import javax.swing.*;import java.awt.*;import java.awt.event.MouseEvent;import java.awt.event.MouseListener;import java.io.IOException;import java.io.ObjectInputStream;import java.io.ObjectOutputStream;import java.net.ConnectException;import java.net.Socket;import java.util.ArrayList;import java.util.Iterator;public class ChessPanel extends JPanel implements MouseListener{    // TODO 从服务器接收来的棋子 ，值不变有问题//   Pieces accept_pieces = new Pieces();//   Pieces send_pieces = new Pieces();    whoWin ifWin =new whoWin() ; // 是否胜利    TcpClient client = null; // 客户端    boolean canPlay = true; // 是否能继续玩    boolean isBlack = true; // 是否黑子，黑1,白2    ArrayList<Pieces> allPieces = new ArrayList<>(); // 存储棋子对象,就是通过这个画图的    int [][] allChess = new int[19][19];    int PanelWidth;    int PanelHeight;    int width = 600;    int height = 600;    int temp = width / 18;    int xbase,ybase;    Image image = Toolkit.getDefaultToolkit().getImage("./src/Media/bg.jpeg"); // "./"表示当前项目下    public ChessPanel(){        this.addMouseListener(this);        try {            Socket socket = new Socket("172.27.29.190", 10086);            //TODO 构建输出输入流,输入输出流问题，先输出后输入            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());            ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());            client = new TcpClient(socket,ois,oos);            new Thread(new getMessage()).start(); // 开启读取的线程        } catch (ConnectException e){            System.out.println("服务器拒绝连接！");        } catch (IOException e) {            e.printStackTrace();        }catch(Exception e ){            e.printStackTrace();        }    }    // 画图部分    public void paintComponent(Graphics g) {        super.paintComponent(g);        PanelWidth = this.getSize().width; // 这两步骤        PanelHeight = this.getSize().height;        xbase = (PanelWidth - width) / 2;        ybase = (PanelHeight - height) / 2;        Graphics2D g2d = (Graphics2D) g;//        this.setBackground(new Color(246, 186, 114));        g2d.drawImage(image,0,0,this.getWidth(),this.getHeight(),this);        int x1, y1, x2, y2;        // 画线        for (int i = 0; i < 19; i++) {            if (i == 0 i == 18) {                    

	  




	  
	  
	  
	  
	  
        郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。

相关文章阅读