java如何实现联机五子棋

这篇文章主要介绍“java如何实现联机五子棋”的相关知识，小编通过实际案例向大家展示操作过程，操作方法简单快捷，实用性强，希望这篇“java如何实现联机五子棋”文章能帮助大家解决问题。

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

这里是代码包的结构：

接着我来依次说下这些类所完成的功能

Media包

Media包：主要是放了五子棋的背景图片和播放音乐的类以及音乐内容

播放音乐这个类是我从室友那拿的，所以我也不是很懂，瞄了一眼是用Applet完成的，只能处理.wav后缀的音乐

Net包

Net包：包含两个类，细心的小伙伴应该注意到客户端是没有主方法的。客户端中其实是包含与服务端进行通信的Socket的，其中包含一些读和写的方法。服务端我采用的是线程池的方法来处理客户端的请求（线程池这部分我也不是特别了解，用起来和多线程感觉差不多）。

View包

View包：包含四个类，分别是ChessBoard,ChessPanel,Pieces和WhoWin 类

ChessBoard是一个包含Main方法的JFrame,命令面板和棋盘面板都是添加到这个JFrame中的。

ChessPanel是一个棋盘面板，里面完成了如：画19*19的棋盘线条，加载背景图片，不停的接收来自服务端的消息并处理（把棋子加到面板），处理每次点击后添加棋子到面板并发送棋子到服务器，判断胜负并且给出提示消息。

Pieces是一个棋子，其中有包含如颜色，棋子半径，棋子位置和命令（和前面的命令面板配合使用，默认是发送）等属性。

WhoWin就是五子棋中判断谁输谁赢的部分。每下一步就需要判断。

播放音乐的类：

package Media.Music;import java.io.File;import java.io.IOException;import javax.sound.sampled.AudioInputStream;import javax.sound.sampled.AudiOSystem;import javax.sound.sampled.Clip;import javax.sound.sampled.LineUnavailableException;import javax.sound.sampled.UnsupportedAudioFileException;public class PlayMusic {    private Clip clip;    public PlayMusic(String filePath) throws LineUnavailableException, UnsupportedAudioFileException, IOException {        File file = new File(filePath);        AudioInputStream audioInputStream = AudioSystem.getAudioInputStream(file);        clip = AudioSystem.getClip();        clip.open(audioInputStream);    }     public void play() {        clip.setFramePosition(1);        clip.start();    }     public void loop() {        clip.loop(Clip.LOOP_CONTINUOUSLY);    }    public void stop() {        clip.stop();    }}

tcpClient:

package net;import view.Pieces;import java.io.*;import java.net.Socket;public class TcpClient{    private Socket socket;    private ObjectInputStream ois;    private ObjectOutputStream oos;    public TcpClient(Socket socket,ObjectInputStream ois,ObjectOutputStream oos){        this.socket= socket;        this.ois = ois;        this.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:

// 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,"It's 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) {                g2d.setStroke(new BasicStroke(3.0f));            } else g2d.setStroke(new BasicStroke(1.0f));            x1 = xbase + temp * i;            y1 = ybase;            y2 = ybase + 18 * temp;            g2d.drawLine(x1, y1, x1, y2);            x1 = xbase;            y1 = ybase + temp * i;            x2 = xbase + temp * 18;            g2d.drawLine(x1, y1, x2, y1);        }        // 开始画棋子        int radius ;        int xPos,yPos;        Iterator it = allPieces.iterator(); // 迭代器遍历arraylist        while(it.hasNext()){            Pieces pieces = (Pieces) it.next();            radius  = pieces.getRadius();            xPos = pieces.getxPos();            yPos = pieces.getyPos();            System.out.println(pieces.getColor()+","+pieces.getxPos()+","+pieces.getyPos());            if (pieces.getColor() == 1){                g2d.setColor(Color.black);                g2d.fillOval(xPos*temp+xbase-radius/2,yPos*temp+ybase-radius/2,radius,radius);            }            else if (pieces.getColor() == 2) {                g2d.setColor(Color.white);                g2d.fillOval(xPos * temp + xbase - radius / 2, yPos * temp + ybase - radius / 2, radius, radius);            }        }     }     @Override    public void mousePressed(MouseEvent e) {        int x ,y ;        if (canPlay) {            x = e.getX();            y = e.getY();            //  判断鼠标点击位置            if (x >= xbase & x <= (xbase + 18 * temp) & y >= ybase & y < (ybase + 18 * temp)) {                // 判断是不是下在空的位置                int tempX = (x - xbase) / temp, tempY = (y - ybase) / temp;                // todo 这里是关键判断这点坐标的数组下标是什么                if ((x - xbase) % temp > temp / 2) {                    x = tempX + 1;                } else                    x = tempX;                if ((y - ybase) % temp > temp / 2)                    y = tempY + 1;                else                    y = tempY;                // 先判断有没有棋子，处理没有棋子的情况                if (allChess[x][y] != 0) {                       JOptionPane.showMessageDialog(this, "这里有棋子了");                } else {                    Pieces send_pieces = new Pieces();                    send_pieces.setxPos(x);                    send_pieces.setyPos(y);                    if (isBlack){                        send_pieces.setColor(1);                        allChess[x][y] = 1;                        isBlack = false;                    }                    else{                        send_pieces.setColor(2);                        allChess[x][y]=2;                        isBlack = true;                    }                    allPieces.add(send_pieces); // 向棋子队列加入当前棋子                    canPlay = false;// canPlay在true情况下， 点击一次后不能点击了                    this.repaint();                    ifWin = new whoWin(allChess,x,y);                    // 如果赢了，就不能玩了，并且给出提示消息，你赢了;                    if(ifWin.isWin()){                        canPlay = false;                        JOptionPane.showMessageDialog(this,"Congratulations you have won tha game !");                    }                    try {                        if (client!=null){                            client.send(send_pieces);                        }                    } catch (IOException ex) {                        ex.printStackTrace();                    }                }            }         }    }     // 读取来自服务器端的信息    class getMessage implements Runnable{        private boolean flag = true;        public void setFlag(boolean flag) {            this.flag = flag;        }         @Override        public void run() {            // 循环读            while(flag){                if(client!=null){                    try {                        Pieces accept_pieces = client.accept();                        String command = accept_pieces.getCommand();                        int color = accept_pieces.getColor();                        switch (command){                            case "发送":{                                canPlay = true;                                if (color == 1){                                    isBlack = false;//对方为黑我为白                                }else{                                    isBlack = true;                                }                                allPieces.add(accept_pieces);                                allChess[accept_pieces.getxPos()][accept_pieces.getyPos()]= accept_pieces.getColor();                                ChessPanel.this.repaint();                                ifWin.setY(accept_pieces.getyPos());                                ifWin.setX(accept_pieces.getxPos());                                ifWin.setAllChess(allChess);                                if(ifWin.isWin()){                                    canPlay = false;                                    JOptionPane.showMessageDialog(ChessPanel.this,"It's a pity you have fail the game!");                                }                                break;                            }                            case "悔棋":{                                int i = JOptionPane.showConfirmDialog(ChessPanel.this,"对方请求悔棋，是否同意！");                                // yes 0,no 1,cancel 2,closed -1                                Pieces pieces = new Pieces();                                if (i == 0){                                    // 同意悔棋:1.同意对方悔棋                                    pieces.setCommand("同意悔棋");                                    // arraylist 去除末尾的两个值，对应allChess置0                                    int size = allPieces.size();                                    for (int j = 1;j<=2;j++){                                        allChess[allPieces.get(size-j).getxPos()][allPieces.get(size-j).getyPos()]=0;                                        allPieces.remove(size-j);                                    }                                    ChessPanel.this.repaint();                                }else if(i==1){                                    pieces.setCommand("不同意悔棋");                                }                                client.send(pieces);                                break;                            }                            case "认输":{ // 不能继续玩下去，你已经胜利                                JOptionPane.showMessageDialog(ChessPanel.this,"对方认输");                                canPlay = false;                                JOptionPane.showMessageDialog(ChessPanel.this,"Congratulations you have won tha game !");                                break;                            }                            case "重新开始":{ // 是否同意重新开始                               int i = JOptionPane.showConfirmDialog(ChessPanel.this,"对方请求重新开始，是否同意");                                Pieces pieces = new Pieces();                                if(i == 0){// allChess 和 allPieces全部置0;                                    pieces.setCommand("同意重新开始");                                    int size = allPieces.size();                                    System.out.println("arraylist 长度："+size);                                    for (int j = 0;j<size;j++){// 移除队首元素                                        allChess[allPieces.get(0).getxPos()][allPieces.get(0).getyPos()] = 0;                                        allPieces.remove(0);                                    }                                    canPlay = true;                                    ChessPanel.this.repaint();                                }else if (i ==1){                                    pieces.setCommand("不同意重新开始");                                }                                client.send(pieces);                                break;                            }                            case "同意悔棋":{// allpieces 和 allchess 回退                                JOptionPane.showMessageDialog(ChessPanel.this,"对方同意悔棋");                                int size = allPieces.size();                                for (int j = 1;j<=2;j++){                                    allChess[allPieces.get(size-j).getxPos()][allPieces.get(size-j).getyPos()]=0;                                    allPieces.remove(size-j);                                }                                ChessPanel.this.repaint();                                break;                            }                            case "不同意悔棋":{                                JOptionPane.showMessageDialog(ChessPanel.this,"对方不同意悔棋");                                break;                            }                             case "同意重新开始":{ // 全部置0,调用repaint 方法                                JOptionPane.showMessageDialog(ChessPanel.this,"对方同意重新开始");                                int size = allPieces.size();                                for (int j = 0;j<size;j++){ //  todo 移除队首元素arraylist 长度改变；序列也发生改变                                    allChess[allPieces.get(0).getxPos()][allPieces.get(0).getyPos()] = 0;                                    allPieces.remove(0);                                }                                canPlay = true;                                ChessPanel.this.repaint();                                break;                            }                            case "不同意重新开始":{                                JOptionPane.showMessageDialog(ChessPanel.this,"对方不同意重新开始");                                break;                            }                            case "对方掉线":{ // 对方已经掉线                                JOptionPane.showMessageDialog(ChessPanel.this,"不好意思，对方已经掉线！");                                canPlay = false;                                break;                            }                        }                    } catch (IOException e) {                        e.printStackTrace();                    } catch (ClassNotFoundException e) {                        e.printStackTrace();                    }                }            }        }    }     @Override    public void mouseClicked(MouseEvent e) {     }    @Override    public void mouseReleased(MouseEvent e) {     }     @Override    public void mouseEntered(MouseEvent e) {     }     @Override    public void mouseExited(MouseEvent e) {     } }

Pieces:

package view; import java.io.Serializable;// 存储棋子的相关信息public class Pieces implements Serializable {    private int radius = 16;    private int color = 0;    private int xPos ;    private int yPos;    private String command = "发送";    public String getCommand() {        return command;    }     public void setCommand(String command) {        this.command = command;    }     public Pieces(int color, int xPos, int yPos){        this.color = color;        this.xPos = xPos;        this.yPos = yPos;    }    public Pieces(){     }    public Pieces(String command){        this.command = command;    }    public int getRadius() {        return radius;    }     public void setRadius(int radius) {        this.radius = radius;    }     public int getColor() {        return color;    }     public void setColor(int color) {        this.color = color;    }     public int getxPos() {        return xPos;    }     public void setxPos(int xPos) {        this.xPos = xPos;    }     public int getyPos() {        return yPos;    }     public void setyPos(int yPos) {        this.yPos = yPos;    }}

WhoWin：

package view;public class whoWin { // 判断是谁赢了    private int allChess[][] = new int[19][19];    private int x = 0;    private int y = 0;    public whoWin(){     }    public whoWin(int allChess[][],int x,int y){        this.allChess = allChess;        this.x = x;        this.y = y;    }     public void setAllChess(int allChess[][]){        this.allChess = allChess;    }    public void setX(int x){        this.x = x;    }    public void setY(int y ){        this.y = y;    }    public boolean isWin() {        int color = allChess[x][y];        int count;        count = this.Count(1, 0, color); // 对横方向的判断        if (count >= 5) {            return true;        } else {            count = this.Count(0, 1, color); // 对竖方向的判断            if (count >= 5) {                return true;            } else {                count = this.Count(1, 1, color); // 对左上方向的判断                if (count >= 5)                    return true;                else {                    count = this.Count(1, -1, color); // 对右上方向的判断                    if (count >= 5)                        return true;                }            }        }        return false;    }    private int Count(int xChange, int yChange, int color) {        int count = 1;        int tempX = xChange, tempY = yChange;        while (color == allChess[x + xChange][y + yChange]) {            count++;            if (xChange != 0) {                xChange++;            }            if (yChange != 0) {                if (yChange > 0)                    yChange++;                else                    yChange--;            }        }        xChange = tempX;        yChange = tempY;        while (color == allChess[x - xChange][y - yChange]) {            count++;            if (xChange != 0)                xChange++;            if (yChange != 0) {                if (yChange > 0)                    yChange++;                else                    yChange--;            }        }        return count;    }}

关于“java如何实现联机五子棋”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识，可以关注编程网精选频道，小编每天都会为大家更新不同的知识点。