全程干货（肢解视频哪能看）肢解方法，肢解（一）-30分钟用JAVA写个QQ吧，java qq空间，

// 1.画一个界面// 设置大小this.setSize(500, 500);// 布局this.setLayout(new FlowLayout());// 标题this.setTitle("服务器1");

jtfRec = new JTextArea(10, 40);jscrollPane = new JScrollPane(jtfRec);this.add(jscrollPane);

jtfSend = new JTextField(40);this.add(jtfSend);

JButton Sendbutton = new JButton("发送");Sendbutton.addActionListener(this);this.add(Sendbutton);

// 2.1创建一个服务器(要记得给定端口)server = new ServerSocket(port);System.out.println("1.成功创建服务器" + port);

// 2.2创建一个Socket甬道来获取输入和输出流 Socket socket;// 用循环来让服务器可以不停地连接客户机 while (true) {System.out.println("2.等待客户机进入");socket = server.accept();//从请求连接队列里取出一个连接也就是让服务器进入阻塞状态 System.out.println("3.已有客户机登录");// 用线程对输入和输出流进行读写操作 ct4 = new ChatThreadV4(socket,jtfSend,jtfRec);ct4.start();System.out.println("4.循环结束了一次");}

public String readString(InputStream ins) throws IOException {reader = new BufferedReader(new InputStreamReader(ins));return reader.readLine();}

private void processChat() throws IOException {//服务器给客户机发送欢迎登陆的消息： String s = "hello,欢迎登录服务器2.0\r\n";// 用一个字节数组来封装，也可不封装 byte[] data = s.getBytes();// 取得组成这个字符串的字节 out.write(data);out.flush();// 2.对输入流进行处理（内有大文章） // 2.1此时的处理是将输入流的字节转为字符串 String inputs = readString(ins);// 2.2用一个判断条件来使服务器和客户机的通信在适当的时候停止 while (!inputs.equals("bye")) {//2.3服务器显示客户机发来的消息(除了用打印语句还可以用JTextAre多行输入框)// System.out.println("客户机说：" + inputs); Chatlog += "（服务器显示接收的消息）客户机说：" + inputs+"\r\n";jtfRec.setText(Chatlog);//发送消息可以另外用一个方法（输入框） // 2.5读取客户机的下一次输入 inputs = readString(ins);}//2.6当通信到了停止的时候，服务器向客户机发送再见的消息 s = "再见，欢迎再来哦！\r\n";data = s.getBytes();// 取得组成这个字符串的字节 out.write(data);out.flush();//2.7 关闭与客户机的连接 socket.close();}//2.3接收消息 public void run() {try {processChat();} catch (IOException e) {// TODO Auto-generated catch block e.printStackTrace();}}

//2.4发送消息 public void sendMsg(String msg) {//2.4.1将服务器发送的消息显示出来 String s1 ="服务器说："+msg+"\r\n";Chatlog +=s1;jtfRec.setText(Chatlog);//发送 String s2 =msg+"\r\n";try{byte[] ba =s2.getBytes();out.write(ba);}catch(Exception e){e.printStackTrace();}}

import java.awt.FlowLayout;import java.awt.event.ActionEvent;import java.awt.event.ActionListener;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;import javax.swing.JButton;import javax.swing.JFrame;import javax.swing.JScrollPane;import javax.swing.JTextArea;import javax.swing.JTextField;//给服务器加一个界面public class ChatServerV4 extends JFrame implements ActionListener {ServerSocket server;JTextField jtfSend;JTextArea jtfRec;JScrollPane jscrollPane;ChatThreadV4 ct4;// 初始化 public void initUI(int port) throws IOException {// 1.画一个界面 // 设置大小 this.setSize(500, 500);// 布局 this.setLayout(new FlowLayout());// 标题 this.setTitle("服务器1");多行输入框内的消息为聊天记录（也就是1.服务器发送给客户机的消息，2.客户机发送给服务器的消息都要显示）jtfRec = new JTextArea(10, 40);// this.add(jtfRec); //滚动条来阅读JTextArea jscrollPane = new JScrollPane(jtfRec);this.add(jscrollPane);// 1.2单行文本输入框内的消息为服务器发送给客户机的消息 // 内部类调用的对象要用Final jtfSend = new JTextField(40);this.add(jtfSend);// 1.3由点击按钮这个事件来发送消息 JButton Sendbutton = new JButton("发送");Sendbutton.addActionListener(this);this.add(Sendbutton);// 可视 this.setVisible(true);// 2.1创建一个服务器(要记得给定端口) server = new ServerSocket(port);System.out.println("1.成功创建服务器" + port);// 2.2创建一个Socket甬道来获取输入和输出流 Socket socket;// 用循环来让服务器可以不停地连接客户机 while (true) {System.out.println("2.等待客户机进入");socket = server.accept();//从请求连接队列里取出一个连接也就是让服务器进入阻塞状态 System.out.println("3.已有客户机登录");// 用线程对输入和输出流进行读写操作 ct4 = new ChatThreadV4(socket,jtfSend,jtfRec);ct4.start();System.out.println("4.循环结束了一次");}}// 主函数 public static void main(String[] args) throws IOException {ChatServerV4 cs4 = new ChatServerV4();cs4.initUI(8888);}public void actionPerformed(ActionEvent arg0) {String msg = jtfSend.getText();ct4.sendMsg(msg);jtfSend.setText("");}}import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.net.Socket;import javax.swing.JTextArea;import javax.swing.JTextField;public class ChatThreadV4 extends Thread {private Socket socket;private InputStream ins;private OutputStream out;private BufferedReader reader;JTextField jtfSend;JTextArea jtfRec;private String Chatlog="客户机已连接成功\r\n";// 构造器 public ChatThreadV4(Socket socket, JTextField jtfSend,JTextArea jtfRec) throws IOException {this.socket = socket;this.jtfSend =jtfSend;this.jtfRec = jtfRec;// 实例化 输入和输出流 this.ins = socket.getInputStream();this.out = socket.getOutputStream();}//2.3接收消息 public void run() {try {processChat();} catch (IOException e) {// TODO Auto-generated catch block e.printStackTrace();}}/** * 处理连接对象：读取客户机发来的字符串，回送给客户机 * * @throws IOException */private void processChat() throws IOException {//服务器给客户机发送欢迎登陆的消息： String s = "hello,欢迎登录服务器2.0\r\n";// 用一个字节数组来封装，也可不封装 byte[] data = s.getBytes();// 取得组成这个字符串的字节 out.write(data);out.flush();// 2.对输入流进行处理（内有大文章） // 2.1此时的处理是将输入流的字节转为字符串 String inputs = readString(ins);// 2.2用一个判断条件来使服务器和客户机的通信在适当的时候停止 while (!inputs.equals("bye")) {//2.3服务器显示客户机发来的消息(除了用打印语句还可以用JTextAre多行输入框)// System.out.println("客户机说：" + inputs); Chatlog += "（服务器显示接收的消息）客户机说：" + inputs+"\r\n";jtfRec.setText(Chatlog);//发送消息可以另外用一个方法（输入框） // 2.5读取客户机的下一次输入 inputs = readString(ins);}//2.6当通信到了停止的时候，服务器向客户机发送再见的消息 s = "再见，欢迎再来哦！\r\n";data = s.getBytes();// 取得组成这个字符串的字节 out.write(data);out.flush();//2.7 关闭与客户机的连接 socket.close();}//2.3.1 首先定义一个方法来把客户机发来的输入流转为字符串 /*** 从输入流对象中读取字节，拼成字符串返回 给一个可以认为字符串结束的结束符：如果读到字节为13（回车符），则认为在回车符以前的是一个字符串 * * @param ins * 输入流对象 * @return 从流上（客户机）读到的字符串 * @throws IOException */public String readString(InputStream ins) throws IOException {reader = new BufferedReader(new InputStreamReader(ins));return reader.readLine();}//2.4发送消息 public void sendMsg(String msg) {//2.4.1将服务器发送的消息显示出来 String s1 ="服务器说："+msg+"\r\n";Chatlog +=s1;jtfRec.setText(Chatlog);//发送 String s2 =msg+"\r\n";try{byte[] ba =s2.getBytes();out.write(ba);}catch(Exception e){e.printStackTrace();}}}

import java.awt.FlowLayout;import java.awt.event.ActionEvent;import java.awt.event.ActionListener;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;import javax.swing.JButton;import javax.swing.JFrame;import javax.swing.JScrollPane;import javax.swing.JTextArea;import javax.swing.JTextField;//给客户机加一个界面public class ClientV2<Final> extends JFrame {JTextField jtfSend;JTextArea jtfRec;JScrollPane jscrollPane;Socket socket;ClientThreadV2 cThread2;// 初始化public void initUI() throws IOException {// 1.画一个界面// 设置大小this.setSize(500, 500);// 布局this.setLayout(new FlowLayout());// 标题this.setTitle("客户机2.0");// 1.1多行输入框内的消息为聊天记录（也就是1.服务器发送给客户机的消息，2.客户机发送给服务器的消息都要显示）jtfRec = new JTextArea(10, 40);// this.add(jtfRec);// 滚动条来阅读JTextAreajscrollPane = new JScrollPane(jtfRec);this.add(jscrollPane);// 1.2单行文本输入框内的消息为服务器发送给客户机的消息jtfSend = new JTextField(40);this.add(jtfSend);// 1.3由点击按钮这个事件来连接服务器JButton Linkbutton = new JButton("连接服务器");this.add(Linkbutton);// 1.4由点击按钮这个事件来触发通信JButton Sendbutton = new JButton("发送");this.add(Sendbutton);// 可视this.setVisible(true);// 2.创建一个socket连接服务器// 2.1 连接（用内部类给按钮加监听器,内部类用到的对象用final）Linkbutton.addActionListener(new ActionListener() {public void actionPerformed(ActionEvent e) {String ip = "192.168.10.65";int port = 8888;System.out.println("即将连接到服务器：" + ip + "port:" + port);try {// 创建一个Socket甬道（指定服务器的ip和port）socket = new java.net.Socket(ip, port);cThread2 = new ClientThreadV2(jtfSend, jtfRec,socket);//2.2接收消息cThread2.start();javax.swing.JOptionPane.showMessageDialog(null, "连接成功");} catch (Exception e1) {javax.swing.JOptionPane.showMessageDialog(null, "连接失败");}}});// 2.3发送消息（用内部类给按钮加监听器,内部类用到的对象用final）Sendbutton.addActionListener(new ActionListener() {public void actionPerformed(ActionEvent e) {String msg = jtfSend.getText();cThread2.sendMsg(msg);jtfSend.setText("");}});}// 主函数public static void main(String[] args) throws IOException {ClientV2 cV2 = new ClientV2();cV2.initUI();}}import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.net.Socket;import javax.swing.JTextArea;import javax.swing.JTextField;public class ClientThreadV2 extends Thread {Socket socket;private java.io.InputStream ins;private java.io.OutputStream out;private BufferedReader reader;private String Chatlog = "成功登录服务器\r\n";JTextField jtfSend;JTextArea jtfRec;// 构造器public ClientThreadV2(JTextField jtfSend, JTextArea jtfRec,Socket socket) throws IOException {this.socket=socket;this.jtfSend = jtfSend;this.jtfRec = jtfRec;// 实例化 输入和输出流（必须在构造器中先实例化ins和out,不然会有空指针）this.ins = socket.getInputStream();this.out = socket.getOutputStream();}// 2.2接收消息(用线程)public void run() {try {ReadMsg();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}// 2.2接收消息 (对输入流进行处理)public void ReadMsg() throws IOException {System.out.println("1111111111111111111");// 2.2.1此时的处理是将输入流的字节转为字符串String inputs = readString(ins);// 2.2.2用一个判断条件来使服务器和客户机的通信在适当的时候停止while (!inputs.equals("bye")) {// 2.2.3客户机显示服务器发来的消息(除了用打印语句还可以用JTextAre多行输入框)// System.out.println("服务器说：" + inputs);Chatlog += "(客户机显示接收的消息 )服务器说：" + inputs + "\r\n";jtfRec.setText(Chatlog);// 2.2.4读取客户机的下一次输入inputs = readString(ins);}//2.2.5当通信到了停止的时候，服务器向客户机发送再见的消息String s = "再见，欢迎再来哦！\r\n";byte[] data = s.getBytes();// 取得组成这个字符串的字节out.write(data);out.flush();//2.7 关闭与客户机的连接socket.close();}/*** 从输入流对象中读取字节，拼成字符串返回 给一个可以认为字符串结束的结束符：如果读到字节为13（回车符），则认为在回车符以前的是一个字符串** @param ins* 输入流对象* @return 从流上（客户机）读到的字符串* @throws IOException*/public String readString(InputStream ins) throws IOException {reader = new BufferedReader(new InputStreamReader(ins));return reader.readLine();}// 2.3发送消息public void sendMsg(String msg) {// 将客户机发送的消息显示出来String s1 = "客户机2.0说："+msg + "\r\n";Chatlog += s1;jtfRec.setText(Chatlog);// 发送String s2 =msg + "\r\n";try {byte[] ba = s2.getBytes();out.write(ba);} catch (Exception e) {e.printStackTrace();}