java+socket實現(xiàn)簡易局域網(wǎng)聊天室
更新時間：2022年05月20日 09:07:19 作者：lyqmeans
這篇文章主要為大家詳細介紹了java+socket實現(xiàn)簡易局域網(wǎng)聊天室，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
本文實例為大家分享了java+socket實現(xiàn)簡易局域網(wǎng)聊天室的具體代碼，供大家參考，具體內(nèi)容如下
服務(wù)器端
ServerFrame.java
package com.eze.chatroom.server;
import java.awt.EventQueue;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.border.EmptyBorder;
import javax.swing.JLabel;
import java.awt.Color;
import java.awt.Font;
import javax.swing.JTextField;
import javax.swing.JButton;
import javax.swing.JOptionPane;
import javax.swing.JTextArea;
import javax.swing.JScrollPane;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import java.awt.event.MouseAdapter;
import java.awt.event.MouseEvent;
public class ServerFrame extends JFrame {
? ? /**
? ? ?*?
? ? ?*/
? ? private static final long serialVersionUID = 1L;
? ? private JPanel contentPane;
? ? private JTextField txtPort;
? ? private JLabel lblOnlineCount;
? ? private JTextArea txtAreaInfo;
? ? private Server server;
? ? private JTextArea txtAreaPals;
? ? /**
? ? ?* Launch the application.
? ? ?*/
? ? public static void main(String[] args) {
? ? ? ? EventQueue.invokeLater(new Runnable() {
? ? ? ? ? ? public void run() {
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? ServerFrame frame = new ServerFrame();
? ? ? ? ? ? ? ? ? ? frame.setVisible(true);
? ? ? ? ? ? ? ? } catch (Exception e) {
? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? });
? ? }
? ? /**
? ? ?* Create the frame.
? ? ?*/
? ? public ServerFrame() {
? ? ? ? this.setTitle("server");
? ? ? ? this.setResizable(false);
? ? ? ? setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
? ? ? ? setBounds(100, 100, 658, 428);
? ? ? ? contentPane = new JPanel();
? ? ? ? contentPane.setForeground(Color.DARK_GRAY);
? ? ? ? contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));
? ? ? ? setContentPane(contentPane);
? ? ? ? contentPane.setLayout(null);
? ? ? ? JLabel lblPort = new JLabel("port :");
? ? ? ? lblPort.setFont(new Font("宋體", Font.PLAIN, 18));
? ? ? ? lblPort.setBounds(14, 13, 72, 31);
? ? ? ? contentPane.add(lblPort);
? ? ? ? txtPort = new JTextField();
? ? ? ? txtPort.addKeyListener(new KeyAdapter() {
? ? ? ? ? ? @Override
? ? ? ? ? ? public void keyTyped(KeyEvent e) {
? ? ? ? ? ? ? ? int c = e.getKeyChar();
? ? ? ? ? ? ? ? if(!(c > KeyEvent.VK_0 && c < KeyEvent.VK_9)){
? ? ? ? ? ? ? ? ? ? e.consume();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? });
? ? ? ? txtPort.setFont(new Font("宋體", Font.PLAIN, 20));
? ? ? ? txtPort.setBounds(89, 18, 138, 24);
? ? ? ? contentPane.add(txtPort);
? ? ? ? txtPort.setColumns(10);
? ? ? ? JScrollPane scrollPane = new JScrollPane();
? ? ? ? scrollPane.setBounds(245, 103, 378, 272);
? ? ? ? contentPane.add(scrollPane);
? ? ? ? txtAreaInfo = new JTextArea();
? ? ? ? scrollPane.setViewportView(txtAreaInfo);
? ? ? ? txtAreaInfo.setFont(new Font("Monospaced", Font.PLAIN, 20));
? ? ? ? JButton btnChange = new JButton("start");
? ? ? ? btnChange.addMouseListener(new MouseAdapter() {
? ? ? ? ? ? private boolean flag = true;
? ? ? ? ? ? @Override
? ? ? ? ? ? public void mouseClicked(MouseEvent e) {
? ? ? ? ? ? ? ? String portStr = txtPort.getText().trim();
? ? ? ? ? ? ? ? boolean isvalid = false;
? ? ? ? ? ? ? ? int port = 9999;
? ? ? ? ? ? ? ? if(!(portStr.startsWith("0") || portStr.equals(""))){
? ? ? ? ? ? ? ? ? ? port = Integer.valueOf(portStr);
? ? ? ? ? ? ? ? ? ? if(port >= 1024 && port <= 65535)
? ? ? ? ? ? ? ? ? ? ? ? isvalid = true;
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? if(!isvalid){
? ? ? ? ? ? ? ? ? ? JOptionPane.showMessageDialog(ServerFrame.this, "invalid port that is expected to put into the range of 1024~65535");
? ? ? ? ? ? ? ? ? ? return;
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? if(flag){
? ? ? ? ? ? ? ? ? ? btnChange.setText("stop");
? ? ? ? ? ? ? ? ? ? txtAreaInfo.append("server started\n");
? ? ? ? ? ? ? ? ? ? flag = false;
? ? ? ? ? ? ? ? ? ? ServerFrame.this.server = new Server(ServerFrame.this, ServerFrame.this.getTitle(), port);
? ? ? ? ? ? ? ? ? ? Thread thdServer = new Thread(new Runnable() {
? ? ? ? ? ? ? ? ? ? ? ? @Override
? ? ? ? ? ? ? ? ? ? ? ? public void run() {
? ? ? ? ? ? ? ? ? ? ? ? ? ? ServerFrame.this.server.start();
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? });
? ? ? ? ? ? ? ? ? ? thdServer.start();
? ? ? ? ? ? ? ? }else{
? ? ? ? ? ? ? ? ? ? btnChange.setText("start");
? ? ? ? ? ? ? ? ? ? ServerFrame.this.server.stop();
? ? ? ? ? ? ? ? ? ? txtAreaInfo.append("server stopped\n");
? ? ? ? ? ? ? ? ? ? flag = true;
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? });
? ? ? ? btnChange.setFont(new Font("宋體", Font.PLAIN, 19));
? ? ? ? btnChange.setBackground(new Color(240, 255, 240));
? ? ? ? btnChange.setForeground(new Color(178, 34, 34));
? ? ? ? btnChange.setBounds(270, 17, 113, 27);
? ? ? ? contentPane.add(btnChange);
? ? ? ? JLabel lblPalsOnline = new JLabel("pals online:");
? ? ? ? lblPalsOnline.setBounds(18, 73, 113, 18);
? ? ? ? contentPane.add(lblPalsOnline);
? ? ? ? JLabel lblLogInfo = new JLabel("log info");
? ? ? ? lblLogInfo.setBounds(285, 73, 72, 18);
? ? ? ? contentPane.add(lblLogInfo);
? ? ? ? lblOnlineCount = new JLabel("0");
? ? ? ? lblOnlineCount.setBounds(123, 75, 72, 18);
? ? ? ? contentPane.add(lblOnlineCount);
? ? ? ? JScrollPane scrollPane_1 = new JScrollPane();
? ? ? ? scrollPane_1.setBounds(14, 111, 213, 264);
? ? ? ? contentPane.add(scrollPane_1);
? ? ? ? txtAreaPals = new JTextArea();
? ? ? ? scrollPane_1.setViewportView(txtAreaPals);
? ? }
? ? public JLabel getLblOnlineCount() {
? ? ? ? return lblOnlineCount;
? ? }
? ? public JTextArea getTxtAreaPals() {
? ? ? ? return txtAreaPals;
? ? }
? ? public JTextArea getTxtAreaInfo() {
? ? ? ? return txtAreaInfo;
? ? }
}Server.java
package com.eze.chatroom.server;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.swing.JTextArea;
public class Server {
? ? private ServerSocket server;
? ? private List<Socket> clients;
? ? private Map<String, String> pals;
? ? @SuppressWarnings("unused")
? ? private String name;
? ? private int port;
? ? private ServerFrame frame;
? ? public Server(ServerFrame frame, String name, int port){
? ? ? ? this.frame = frame;
? ? ? ? this.name = name;
? ? ? ? this.port = port;
? ? ? ? this.clients = new ArrayList<>();
? ? ? ? this.pals = new HashMap<>();
? ? }
? ? public void start(){
? ? ? ? try {
? ? ? ? ? ? this.server = new ServerSocket(port);
? ? ? ? ? ? System.out.println("server start at port "+port);
? ? ? ? ? ? while(true){
? ? ? ? ? ? ? ? Socket client = server.accept();
? ? ? ? ? ? ? ? Thread thdHandConn = new Thread(new HandleConnection(client, clients, pals, frame));
? ? ? ? ? ? ? ? thdHandConn.start();
? ? ? ? ? ? }
? ? ? ? }catch(SocketException e){
? ? ? ? ? ? System.out.println("server stop");
? ? ? ? }catch (IOException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }
? ? }
? ? public void stop(){
? ? ? ? try {
? ? ? ? ? ? for(Socket sock : clients){
? ? ? ? ? ? ? ? sock.close();
? ? ? ? ? ? }
? ? ? ? ? ? server.close();
? ? ? ? } catch (IOException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }
? ? }
? ? public static void autoRoll(JTextArea area){
? ? ? ? area.setCaretPosition(area.getText().length());
? ? }
}HandleConnnection.java
package com.eze.chatroom.server;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.SocketException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Map;
public class HandleConnection implements Runnable {
? ? private Socket client;
? ? private List<Socket> clients;
? ? private Map<String, String> pals;
? ? private ServerFrame frame;
? ? public HandleConnection(Socket client, List<Socket> clients, Map<String, String> pals, ServerFrame frame){
? ? ? ? this.client = client;
? ? ? ? this.clients = clients;
? ? ? ? this.pals = pals;
? ? ? ? this.frame = frame;
? ? }
? ? @Override
? ? public void run() {
? ? ? ? String username = null;
? ? ? ? SimpleDateFormat formatDate = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
? ? ? ? try {
? ? ? ? ? ? DataInputStream dataInput = new DataInputStream(client.getInputStream());
? ? ? ? ? ? DataOutputStream dataOutput = new DataOutputStream(client.getOutputStream());
? ? ? ? ? ? String totalFirst = dataInput.readUTF();
? ? ? ? ? ? username = totalFirst.split("_")[0];
? ? ? ? ? ? if(username.equals("")){
? ? ? ? ? ? ? ? dataOutput.writeUTF("no");
? ? ? ? ? ? ? ? client.close();
? ? ? ? ? ? ? ? return;
? ? ? ? ? ? }
? ? ? ? ? ? dataOutput.writeUTF("ok");
? ? ? ? ? ? String hello = formatDate.format(new Date())+"\n"+client.getRemoteSocketAddress().toString()+username+" join romm\n";
? ? ? ? ? ? frame.getTxtAreaInfo().append(hello);
? ? ? ? ? ? Server.autoRoll(frame.getTxtAreaInfo());
? ? ? ? ? ? this.forwardMsg(hello);
? ? ? ? ? ? clients.add(client);
? ? ? ? ? ? pals.put(client.getRemoteSocketAddress().toString(), username);
? ? ? ? ? ? this.updatePalsList();
? ? ? ? ? ? while(true){
? ? ? ? ? ? ? ? String word = dataInput.readUTF();
? ? ? ? ? ? ? ? String date = formatDate.format(new Date());
? ? ? ? ? ? ? ? String msg = date+" "+username+"\n"+word;
? ? ? ? ? ? ? ? frame.getTxtAreaInfo().append(msg+"\n");
? ? ? ? ? ? ? ? Server.autoRoll(frame.getTxtAreaInfo());
? ? ? ? ? ? ? ? this.forwardMsg(msg);
? ? ? ? ? ? }
? ? ? ? }catch (SocketException e) {
? ? ? ? ? ? clients.remove(client);
? ? ? ? ? ? pals.remove(client.getRemoteSocketAddress().toString(), username);
? ? ? ? ? ? this.updatePalsList();
? ? ? ? ? ? String leaveMsg = formatDate.format(new Date())+"\n"+username+" leaved room\n";
? ? ? ? ? ? this.frame.getTxtAreaInfo().append(leaveMsg);
? ? ? ? ? ? Server.autoRoll(frame.getTxtAreaInfo());
? ? ? ? ? ? this.forwardMsg(leaveMsg);
? ? ? ? }catch (IOException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }
? ? }
? ? protected void updatePalsList(){
? ? ? ? this.frame.getLblOnlineCount().setText(String.valueOf(clients.size()));
? ? ? ? this.frame.getTxtAreaPals().setText("");
? ? ? ? for(Map.Entry<String, String> entry : pals.entrySet()){
? ? ? ? ? ? this.frame.getTxtAreaPals().append(entry.getKey()+" "+entry.getValue()+"\n");
? ? ? ? }
? ? }
? ? protected void forwardMsg(String msg){
? ? ? ? try {
? ? ? ? ? ? for(Socket sock : clients){
? ? ? ? ? ? ? ? if(sock != client){
? ? ? ? ? ? ? ? ? ? DataOutputStream dataOutput = new DataOutputStream(sock.getOutputStream());
? ? ? ? ? ? ? ? ? ? dataOutput.writeUTF(msg);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? } catch (IOException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }
? ? }
}客戶端
ClientLoginViewer.java
package com.eze.chatroom.client;
import java.awt.EventQueue;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.border.EmptyBorder;
import javax.swing.JLabel;
import javax.swing.JOptionPane;
import javax.swing.JTextField;
import javax.swing.JButton;
import java.awt.Font;
import java.awt.event.MouseAdapter;
import java.awt.event.MouseEvent;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import java.awt.event.ActionListener;
import java.awt.event.ActionEvent;
public class ClientLoginViewer extends JFrame {
? ? /**
? ? ?*?
? ? ?*/
? ? private static final long serialVersionUID = 1L;
? ? private JPanel contentPane;
? ? private ClientWin win;
? ? private JTextField txtUsername;
? ? private JTextField txtServer;
? ? private JLabel lblPort;
? ? private JTextField txtPort;
? ? private Client client;
? ? /**
? ? ?* Launch the application.
? ? ?*/
? ? public static void main(String[] args) {
? ? ? ? EventQueue.invokeLater(new Runnable() {
? ? ? ? ? ? public void run() {
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? ClientLoginViewer frame = new ClientLoginViewer();
? ? ? ? ? ? ? ? ? ? frame.setVisible(true);
? ? ? ? ? ? ? ? } catch (Exception e) {
? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? });
? ? }
? ? /**
? ? ?* Create the frame.
? ? ?*/
? ? public ClientLoginViewer() {
? ? ? ? setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
? ? ? ? setBounds(100, 100, 603, 366);
? ? ? ? contentPane = new JPanel();
? ? ? ? contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));
? ? ? ? setContentPane(contentPane);
? ? ? ? contentPane.setLayout(null);
? ? ? ? JLabel lblNewLabel = new JLabel("username:");
? ? ? ? lblNewLabel.setFont(new Font("宋體", Font.PLAIN, 20));
? ? ? ? lblNewLabel.setBounds(71, 41, 113, 18);
? ? ? ? contentPane.add(lblNewLabel);
? ? ? ? txtUsername = new JTextField();
? ? ? ? txtUsername.setText("admin");
? ? ? ? txtUsername.setBounds(209, 38, 235, 24);
? ? ? ? contentPane.add(txtUsername);
? ? ? ? txtUsername.setColumns(10);
? ? ? ? JLabel lblServer = new JLabel("server:");
? ? ? ? lblServer.setFont(new Font("宋體", Font.PLAIN, 20));
? ? ? ? lblServer.setBounds(71, 93, 90, 18);
? ? ? ? contentPane.add(lblServer);
? ? ? ? txtServer = new JTextField();
? ? ? ? txtServer.setText("localhost");
? ? ? ? txtServer.setColumns(10);
? ? ? ? txtServer.setBounds(209, 92, 235, 24);
? ? ? ? contentPane.add(txtServer);
? ? ? ? lblPort = new JLabel("port:");
? ? ? ? lblPort.setFont(new Font("宋體", Font.PLAIN, 20));
? ? ? ? lblPort.setBounds(71, 149, 90, 18);
? ? ? ? contentPane.add(lblPort);
? ? ? ? txtPort = new JTextField();
? ? ? ? txtPort.setText("2222");
? ? ? ? txtPort.addKeyListener(new KeyAdapter() {
? ? ? ? ? ? @Override
? ? ? ? ? ? public void keyTyped(KeyEvent e) {
? ? ? ? ? ? ? ? int c = e.getKeyChar();
? ? ? ? ? ? ? ? if(c < KeyEvent.VK_0 || c > KeyEvent.VK_9){
? ? ? ? ? ? ? ? ? ? e.consume();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? });
? ? ? ? txtPort.setBounds(209, 148, 235, 24);
? ? ? ? contentPane.add(txtPort);
? ? ? ? txtPort.setColumns(10);
? ? ? ? JButton btnLogin = new JButton("login");
? ? ? ? btnLogin.addActionListener(new ActionListener() {
? ? ? ? ? ? public void actionPerformed(ActionEvent e) {
? ? ? ? ? ? }
? ? ? ? });
? ? ? ? btnLogin.addMouseListener(new MouseAdapter() {
? ? ? ? ? ? @Override
? ? ? ? ? ? public void mouseClicked(MouseEvent e) {
? ? ? ? ? ? ? ? String username = txtUsername.getText();
? ? ? ? ? ? ? ? String server = txtServer.getText();
? ? ? ? ? ? ? ? String portStr = txtPort.getText();
? ? ? ? ? ? ? ? if(!this.argsValid(username, server, portStr)){
? ? ? ? ? ? ? ? ? ? String error = "please input valid arguments which username, password, server, port"
? ? ? ? ? ? ? ? ? ? ? ? ? ? + " are not allowed be empty and port should be in the range of 1024~65535";
? ? ? ? ? ? ? ? ? ? JOptionPane.showMessageDialog(ClientLoginViewer.this, error);
? ? ? ? ? ? ? ? ? ? return;
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? client = new Client(username, server, Integer.valueOf(portStr), ClientLoginViewer.this.win);
? ? ? ? ? ? ? ? if(ClientLoginViewer.this.client.login()){
? ? ? ? ? ? ? ? ? ? ClientLoginViewer.this.setVisible(false);
? ? ? ? ? ? ? ? ? ? ClientLoginViewer.this.win.setVisible(true);
? ? ? ? ? ? ? ? ? ? win.setClient(client);
? ? ? ? ? ? ? ? }else{
? ? ? ? ? ? ? ? ? ? JOptionPane.showMessageDialog(ClientLoginViewer.this, "login falied");
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? ? ? protected boolean argsValid(String username, String server, String portStr){
? ? ? ? ? ? ? ? if(username.equals("") || server.equals("") || portStr.equals(""))
? ? ? ? ? ? ? ? ? ? return false;
? ? ? ? ? ? ? ? int port = Integer.valueOf(portStr);
? ? ? ? ? ? ? ? if(port < 1024 || port > 65535)
? ? ? ? ? ? ? ? ? ? return false;
? ? ? ? ? ? ? ? return true;
? ? ? ? ? ? }
? ? ? ? });
? ? ? ? btnLogin.setFont(new Font("宋體", Font.PLAIN, 20));
? ? ? ? btnLogin.setBounds(213, 222, 113, 27);
? ? ? ? contentPane.add(btnLogin);
? ? ? ? this.initOther();
? ? }
? ? protected void initOther(){
? ? ? ? this.win = new ClientWin();
? ? ? ? this.setResizable(false);
? ? }
}ClientWin.java
package com.eze.chatroom.client;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.border.EmptyBorder;
import com.eze.chatroom.server.Server;
import javax.swing.JTextField;
import javax.swing.JScrollPane;
import javax.swing.JButton;
import java.awt.Font;
import javax.swing.JTextArea;
import java.awt.event.MouseAdapter;
import java.awt.event.MouseEvent;
import java.io.DataOutputStream;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;
public class ClientWin extends JFrame {
? ? /**
? ? ?*?
? ? ?*/
? ? private static final long serialVersionUID = 1L;
? ? private JPanel contentPane;
? ? private JTextField txtSendMsg;
? ? private JTextArea txtAreaShowMsg;
? ? @SuppressWarnings("unused")
? ? private Client client;
? ? private DataOutputStream dataOutput;
? ? private JScrollPane scrollPane;
? ? /**
? ? ?* Create the frame.
? ? ?*/
? ? public ClientWin() {
? ? ? ? setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
? ? ? ? setBounds(100, 100, 631, 467);
? ? ? ? contentPane = new JPanel();
? ? ? ? contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));
? ? ? ? setContentPane(contentPane);
? ? ? ? contentPane.setLayout(null);
? ? ? ? scrollPane = new JScrollPane();
? ? ? ? scrollPane.setBounds(7, 7, 595, 351);
? ? ? ? contentPane.add(scrollPane);
? ? ? ? txtAreaShowMsg = new JTextArea();
? ? ? ? txtAreaShowMsg.setFont(new Font("Monospaced", Font.PLAIN, 20));
? ? ? ? scrollPane.setViewportView(txtAreaShowMsg);
? ? ? ? txtSendMsg = new JTextField();
? ? ? ? txtSendMsg.setBounds(14, 371, 265, 41);
? ? ? ? txtSendMsg.setFont(new Font("宋體", Font.PLAIN, 20));
? ? ? ? contentPane.add(txtSendMsg);
? ? ? ? txtSendMsg.setColumns(10);
? ? ? ? JButton btnPost = new JButton("post");
? ? ? ? btnPost.addMouseListener(new MouseAdapter() {
? ? ? ? ? ? private SimpleDateFormat dateFormate = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
? ? ? ? ? ? @Override
? ? ? ? ? ? public void mouseClicked(MouseEvent e) {
? ? ? ? ? ? ? ? String sendMsg = txtSendMsg.getText();
? ? ? ? ? ? ? ? if(!sendMsg.equals("")){
? ? ? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? ? ? String date = dateFormate.format(new Date());
? ? ? ? ? ? ? ? ? ? ? ? dataOutput.writeUTF(sendMsg);
? ? ? ? ? ? ? ? ? ? ? ? ClientWin.this.getTxtAreaShowMsg().append(date+" you\n"+sendMsg+"\n");
? ? ? ? ? ? ? ? ? ? ? ? Server.autoRoll(ClientWin.this.getTxtAreaShowMsg());
? ? ? ? ? ? ? ? ? ? ? ? ClientWin.this.txtSendMsg.setText("");
? ? ? ? ? ? ? ? ? ? } catch (IOException e1) {
? ? ? ? ? ? ? ? ? ? ? ? e1.printStackTrace();
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? });
? ? ? ? btnPost.setBounds(377, 378, 113, 27);
? ? ? ? btnPost.setFont(new Font("宋體", Font.PLAIN, 20));
? ? ? ? contentPane.add(btnPost);
? ? ? ? this.initOther();
? ? }
? ? protected void initOther(){
? ? ? ? this.setResizable(false);
? ? }
? ? public void setClient(Client client) {
? ? ? ? this.client = client;
? ? ? ? try {
? ? ? ? ? ? this.dataOutput = new DataOutputStream(client.getClient().getOutputStream());
? ? ? ? } catch (IOException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }
? ? }
? ? public JTextArea getTxtAreaShowMsg() {
? ? ? ? return txtAreaShowMsg;
? ? }
? ? public void setTxtSendMsg(JTextField txtSendMsg) {
? ? ? ? this.txtSendMsg = txtSendMsg;
? ? }
}Client.java
package com.eze.chatroom.client;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
import javax.swing.JOptionPane;
public class Client {
? ? private Socket client;
? ? private String username;
? ? private String server;
? ? private int port;
? ? private ClientWin win;
? ? public Client(String username, String server, int port, ClientWin win){
? ? ? ? this.username = username;
? ? ? ? this.server = server;
? ? ? ? this.port = port;
? ? ? ? this.win = win;
? ? }
? ? public boolean login(){
? ? ? ? try {
? ? ? ? ? ? client = new Socket(server, port);
? ? ? ? ? ? DataInputStream dataInput = new DataInputStream(client.getInputStream());
? ? ? ? ? ? DataOutputStream dataOutput = new DataOutputStream(client.getOutputStream());
? ? ? ? ? ? dataOutput.writeUTF(username+"_");
? ? ? ? ? ? String ret = dataInput.readUTF();
? ? ? ? ? ? if(ret.contains("ok")){
? ? ? ? ? ? ? ? Thread thdReader = new Thread(new ClientReader(client, win));
? ? ? ? ? ? ? ? thdReader.start();
? ? ? ? ? ? ? ? return true;
? ? ? ? ? ? }
? ? ? ? } catch (UnknownHostException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? JOptionPane.showMessageDialog(win, "unknown host");
? ? ? ? } catch (IOException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }
? ? ? ? return false;
? ? }
? ? public Socket getClient() {
? ? ? ? return client;
? ? }
}ClientReader.java
package com.eze.chatroom.client;
import java.io.DataInputStream;
import java.io.IOException;
import java.net.Socket;
import javax.swing.JOptionPane;
import com.eze.chatroom.server.Server;
public class ClientReader implements Runnable {
? ? private ClientWin win;
? ? private Socket client;
? ? public ClientReader(Socket client ,ClientWin win){
? ? ? ? this.client = client;
? ? ? ? this.win = win;
? ? }
? ? @Override
? ? public void run() {
? ? ? ? this.doHand();
? ? }
? ? protected void doHand(){
? ? ? ? try {
? ? ? ? ? ? DataInputStream dataInput = new DataInputStream(client.getInputStream());
? ? ? ? ? ? while(true){
? ? ? ? ? ? ? ? String msg = dataInput.readUTF();
? ? ? ? ? ? ? ? win.getTxtAreaShowMsg().append(msg+"\n");
? ? ? ? ? ? ? ? Server.autoRoll(win.getTxtAreaShowMsg());
? ? ? ? ? ? }
? ? ? ? } catch (IOException e) {
? ? ? ? ? ? //e.printStackTrace();
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? client.close();
? ? ? ? ? ? } catch (IOException e1) {
? ? ? ? ? ? ? ? e1.printStackTrace();
? ? ? ? ? ? }
? ? ? ? ? ? System.out.println("client disconnected");
? ? ? ? ? ? JOptionPane.showMessageDialog(win, "you have been disconnected");
? ? ? ? }
? ? }
}運行效果
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要介紹了Mybatis mapper配置文件xml存放位置,本文給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友參考下吧2023-12-12
解決Test類中不能使用Autowired注入bean的問題
這篇文章主要介紹了解決Test類中不能使用Autowired注入bean的問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-09-09
這篇文章主要介紹了+= 和 ++ 操作符區(qū)別簡單介紹的相關(guān)資料,非常不錯，具有參考借鑒價值，需要的朋友可以參考下2016-09-09
這篇文章將通過三個案例帶大家了解一下Java中的多線程編程，文中的示例代碼介紹詳細，對我們的學(xué)習(xí)或工作有一定的價值，感興趣的小伙伴可以了解一下2022-07-07
這篇文章主要介紹了淺談Java BitSet使用場景和代碼示例，具有一定借鑒價值，需要的朋友可以參考下。2017-12-12
Java 數(shù)據(jù)庫時間返回前端顯示錯誤(差8個小時)的解決方法
本文主要介紹了Java 數(shù)據(jù)庫時間返回前端顯示錯誤(差8個小時)的解決方法,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-08-08
Java實現(xiàn)基于JDBC操作mysql數(shù)據(jù)庫的方法
這篇文章主要介紹了Java實現(xiàn)基于JDBC操作mysql數(shù)據(jù)庫的方法,結(jié)合實例形式分析了java使用JDBC實現(xiàn)針對mysql數(shù)據(jù)庫的連接、查詢、輸出等相關(guān)操作技巧,需要的朋友可以參考下2017-12-12
這篇文章主要介紹了Netty結(jié)合Protobuf進行編解碼,通過文檔表述和代碼實例充分說明了如何進行使用和操作,需要的朋友可以參考下2021-06-06
本篇文章給大家分享Spring Boot 實現(xiàn)圖片上傳并回顯功能，文中通過實例代碼給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友參考下吧2021-07-07
淺談Java中的interface應(yīng)用與面向接口編程
這篇文章主要介紹了淺談Java中的interface應(yīng)用與面向接口編程,Java的關(guān)鍵字interface應(yīng)用,一個接口,多個實現(xiàn)類,面向接口編程,把業(yè)務(wù)邏輯線提取出來作為接口,具體的業(yè)務(wù)實現(xiàn)通過該接口的實現(xiàn)類來完成,需要的朋友可以參考下2023-10-10