北京微信网站建设费用,制作好网站,南宁网站建设服务公司,公司取名软件多人聊天包
由于要先创建服务面板#xff0c;接收客户端连接的信息#xff0c;此代码使用顺序为先启动服务端#xff0c;在启动客户端#xff0c;服务端不用关#xff0c;不然会报错。多运行几次客户端#xff0c;实现单人聊天 1.创建服务面板
package yiduiy;import j…多人聊天包
由于要先创建服务面板接收客户端连接的信息此代码使用顺序为先启动服务端在启动客户端服务端不用关不然会报错。多运行几次客户端实现单人聊天 1.创建服务面板
package yiduiy;import java.awt.BorderLayout;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.Set;
import javax.swing.JFrame;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;public class fuwumianban extends JFrame {private JTextArea ta_info;private ServerSocket server; // 声明ServerSocket对象private Socket socket; // 声明Socket对象socketprivate HashtableString, Socket map new HashtableString, Socket();// 用于存储连接到服务器的用户和客户端套接字对象public void createSocket() {try {server new ServerSocket(1978);while (true) {ta_info.append(等待新客户连接......\n);socket server.accept();// 创建套接字对象ta_info.append(客户端连接成功。 socket \n);new ServerThread(socket).start();// 创建并启动线程对象}} catch (IOException e) {e.printStackTrace();}}class ServerThread extends Thread {Socket socket;public ServerThread(Socket socket) {this.socket socket;}public void run() {try {BufferedReader in new BufferedReader(new InputStreamReader(socket.getInputStream()));// 创建输入流对象while (true) {String info in.readLine();// 读取信息String key ;if (info.startsWith(用户)) {// 添加登录用户到客户端列表key info.substring(3, info.length());// 获得用户名并作为键使用map.put(key, socket);// 添加键值对SetString set map.keySet();// 获得集合中所有键的Set视图IteratorString keyIt set.iterator();// 获得所有键的迭代器while (keyIt.hasNext()) {String receiveKey keyIt.next();// 获得表示接收信息的键Socket s map.get(receiveKey);// 获得与该键对应的套接字对象PrintWriter out new PrintWriter(s.getOutputStream(), true);// 创建输出流对象IteratorString keyIt1 set.iterator();// 获得所有键的迭代器while (keyIt1.hasNext()) {String receiveKey1 keyIt1.next();// 获得键用于向客户端添加用户列表out.println(receiveKey1);// 发送信息out.flush();// 刷新输出缓冲区}}} else {// 转发接收的消息key info.substring(info.indexOf(发送给) 5, info.indexOf(的信息是));// 获得接收方的key值,即接收方的用户名String sendUser info.substring(0, info.indexOf(发送给));// 获得发送方的key值,即发送方的用户名SetString set map.keySet();// 获得集合中所有键的Set视图IteratorString keyIt set.iterator();// 获得所有键的迭代器while (keyIt.hasNext()) {String receiveKey keyIt.next();// 获得表示接收信息的键if (key.equals(receiveKey) !sendUser.equals(receiveKey)) {// 如果是发送方但不是用户本身Socket s map.get(receiveKey);// 获得与该键对应的套接字对象PrintWriter out new PrintWriter(s.getOutputStream(), true);// 创建输出流对象out.println(MSG:info);// 发送信息out.flush();// 刷新输出缓冲区}}}}} catch (IOException e) {ta_info.append(socket 已经退出。\n);}}}public static void main(String args[]) {fuwumianban frame new fuwumianban();frame.setVisible(true);frame.createSocket();}public fuwumianban() {super();setTitle(多个用户聊天);setBounds(100, 100, 385, 266);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);final JScrollPane scrollPane new JScrollPane();getContentPane().add(scrollPane, BorderLayout.CENTER);ta_info new JTextArea();scrollPane.setViewportView(ta_info);}
}2.创建客户面板
package yiduid;import java.awt.BorderLayout;
import java.awt.Dimension;
import java.awt.EventQueue;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;public class kehuframe extends JFrame {private JTextArea ta_info;private JTextField tf_send;PrintWriter out;// 声明输出流对象/*** Launch the application* * param args*/public static void main(String args[]) {EventQueue.invokeLater(new Runnable() {public void run() {try {kehuframe frame new kehuframe();frame.setVisible(true);frame.createClientSocket();} catch (Exception e) {e.printStackTrace();}}});}public void createClientSocket() {try {Socket socket new Socket(127.0.0.1, 1978);// 连接本地1978端口out new PrintWriter(socket.getOutputStream(), true);// 创建输出流对象new ClientThread(socket).start();// 创建并启动线程对象} catch (UnknownHostException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}class ClientThread extends Thread {Socket socket;public ClientThread(Socket socket) {this.socket socket;}public void run() {try {BufferedReader in new BufferedReader(new InputStreamReader(socket.getInputStream()));// 创建输入流对象while (true) {String info in.readLine();// 读取信息ta_info.append(info \n);// 在文本域中显示信息if (info.equals(88)) {break;// 结束线程}}} catch (IOException e) {e.printStackTrace();}}}private void send() {String info tf_send.getText();// 获得输入的信息if (info.equals()) {return;// 如果没输入信息则返回即不发送}if (info.equals(88)) {System.exit(0);// 如果没输入信息是88则退出}out.println(info);// 发送信息out.flush();// 刷新输出缓冲区tf_send.setText(null);// 清空文本框}public kehuframe() { //创建面板super();setTitle(客户互相聊天);setBounds(100, 100, 385, 266);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);final JPanel panel new JPanel();getContentPane().add(panel, BorderLayout.SOUTH);final JLabel label new JLabel();label.setText(输入聊天内容);panel.add(label);tf_send new JTextField();tf_send.addActionListener(new ActionListener() {public void actionPerformed(final ActionEvent e) {send();}});tf_send.setPreferredSize(new Dimension(180, 25));panel.add(tf_send);final JButton button new JButton();button.addActionListener(new ActionListener() {public void actionPerformed(final ActionEvent e) {send();}});button.setText(发 送);panel.add(button);final JScrollPane scrollPane new JScrollPane();getContentPane().add(scrollPane, BorderLayout.CENTER);ta_info new JTextArea();scrollPane.setViewportView(ta_info);}}第二种方法
控制台输出
1.服务界面
package duorenliaotian;import java.io.*;
import java.net.*;
import java.util.ArrayList;
public class Server{public static ServerSocket server_socket;public static ArrayListSocket socketListnew ArrayListSocket(); public static void main(String []args){try{server_socket new ServerSocket(5000);while(true){Socket socket server_socket.accept();socketList.add(socket); //把sock对象加入sock集合ServerBO_Thread stnew ServerBO_Thread(socket,socketList); //初始化多线程st.start();//启动多线程}}catch(Exception ex){ex.printStackTrace();}finally{try{if(server_socket!null){server_socket.close();}}catch(Exception ex){ex.printStackTrace();}}}public void encryptWrite(String src,DataOutputStream output)throws IOException{//将一个字符串转化为字符数组//System.out.println(src);char[] char_arr src.toCharArray();//加密操作for(int i 0;ichar_arr.length;i){output.writeChar(char_arr[i]13);}//用作结束标志符output.writeChar(2333);output.flush();}//读取并解密public String readDecrypt(DataInputStream input)throws IOException{String rtn;while(true){int char_src input.readChar();if(char_src!2333){rtnrtn(char)(char_src-13);}else{break;}}return rtn;}
}
class ServerBO_Thread extends Thread{Socket client null;ArrayListSocket clients;ServerBO_Thread(Socket s,ArrayListSocket ss){//初始化clients;clientsss; }public void run(){DataInputStream input null;DataOutputStream output null;try{input new DataInputStream(client.getInputStream());Server bo new Server();String receivenull;String sendnull;while(true){//监视当前客户端有没有发来消息if(!client.isClosed()){receivebo.readDecrypt(input);clients.trimToSize();String[] param receive.split();if()start.equals(param[1])){ //分析客户端发来的内容send param[0]进入聊天室;}else{send param[0]说: param[1];}if(!(3333.equals(param[1]))){//3333为退出聊天室信号for(Socket socket:clients){ //遍历socke集合 //把读取到的消息发送给各个客户端 if(!socket.isClosed()){output new DataOutputStream(socket.getOutputStream());bo.encryptWrite(send,output);}} }else{//如果有客户端退出for(Socket socket:clients){ //遍历socke集合 if(socket!client){//告诉其他人此人退出聊天室if(!(socket.isClosed())){output new DataOutputStream(socket.getOutputStream());bo.encryptWrite(param[0]已退出聊天室,output);}}}output new DataOutputStream(client.getOutputStream());bo.encryptWrite(3333,output);//返回信号给要退出的客户端然后关闭线程client.close();input.close();output.close();}}else{break;}}}catch(Exception ex){ex.printStackTrace();}}
}
2.客户
package duorenliaotian;
import java.io.IOException;
import java.util.Scanner;
import java.net.*;
import java.io.*;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.BufferedWriter;
import java.io.BufferedReader;
import java.io.DataOutputStream;
public class Cilent{
//服务端ippublic String ip 127.0.0.1;//服务端端口public int port 5000;public DataOutputStream output null;public Socket socket null;public DataInputStream input null;public Scanner sc new Scanner (System.in);public String send ;public String receive;public String name;public String sd null;public static void main(String[]aa){Cilent po new Cilent();po.start();}public void start(){try{System.out.println(*******欢迎使用匿名聊天室**********);System.out.println(请输入你将要使用的昵称);namesc.nextLine();//获取昵称socket new Socket(ip,port);outputnew DataOutputStream(socket.getOutputStream());input new DataInputStream(socket.getInputStream());send name)start;//把昵称发送到server 告诉所有人有新成员加入聊天室System.out.println((如果要退出聊天室请输入“3333”));System.out.println(*******成功进入匿名聊天室**********);System.out.println();encryptWrite(send,output);Out outnew Out(output,name,input,socket);out.start();//启动发送聊天内容的多线程while(true){ String receive readDecrypt(input);if(3333.equals(receive)){//如果收到“3333”则退出聊天室System.out.println(*******成功退出匿名聊天室**********);input.close();output.close();socket.close();System.exit(0);}System.out.println(receive);}}catch(Exception ex){ex.printStackTrace();}finally{try{if(socket!null) socket.close();input.close();output.close();}catch(Exception ex){ex.printStackTrace();}} }public void encryptWrite(String src,DataOutputStream output)throws IOException{//将一个字符串转化为字符数组char[] char_arr src.toCharArray();//加密操作for(int i 0;ichar_arr.length;i){output.writeChar(char_arr[i]13);}//用作结束标志符output.writeChar(2333);output.flush();}//读取并解密public String readDecrypt(DataInputStream input)throws IOException{String rtn;while(true){int char_src input.readChar();if(char_src!2333){rtnrtn(char)(char_src-13);}else{break;}}return rtn;}
}
class Out extends Thread {public DataOutputStream output;public DataInputStream input;public static String name;public Socket socket;public Scanner sc new Scanner (System.in);Out(DataOutputStream ot,String n,DataInputStream it,Socket socket){outputot;inputit;namen;}public void run(){Cilent po new Cilent();try{while(true){String sendsc.nextLine();//获取用户输入String send2namesend;//把聊天内容打包成约定形式po.encryptWrite(send2,output);}}catch(Exception ex){ex.printStackTrace();}finally{System.out.println(sfef);}}
}
