java+socket实现简易局域网聊天室（socket编程怎么跨局域网通信）

本文实例为大家分享了java+socket实现简易局域网聊天室的具体代码，供大家参考，具体内容如下

服务器端

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 clients;

private Map 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 clients;

private Map pals;

private ServerFrame frame;

public HandleConnection(Socket client, List clients, Map 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 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.printSthfmZCBTMackTrace();

}

}

});

}

/**

* 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+"_");

http:// 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

packagehttp:// 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");

}

}

}

运行效果

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。