Java TCP 群聊

服务器：

TCPServer ：

import java.io.*;
import java.net.*;
import java.util.ArrayList;

public class TCPServer {
// 创建一个集合，集合存放客服端的对象
ArrayList<Socket> arrayListSocket = new ArrayList<Socket>();

TCPServer() {
ServerSocket ss;
try {
ss = new ServerSocket(30001);
while (true) {
// 等待客服端连接，一旦有客服端连接服务器，将客服端对象存放到集合中
Socket socket = ss.accept();
arrayListSocket.add(socket);
String ip = socket.getInetAddress().getHostAddress();
System.out.println("ip: " + ip + " 上线了！");
new Thread(new acceptClient(socket, ip)).start();
}

} catch (IOException e) {

e.printStackTrace();
}

}

class acceptClient implements Runnable {
Socket s;
String ip;

acceptClient(Socket s, String ip) {
this.s = s;
this.ip = ip;
}

@Override
public void run() {

try {
// 通知用户上线消息
for (int i = 0; i < arrayListSocket.size(); i++) {
Socket client = arrayListSocket.get(i);
// 下面PrintWriter是可以自带刷新缓存工作，可以简化写入流的操作，
PrintWriter pout = new PrintWriter(client.getOutputStream(), true);
pout.println(ip + "上线了！！！");
}
while (true) {
// 读取Socket读取流中的数据
BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
String line = bufIn.readLine();
// 下面PrintWriter是可以自带刷新缓存工作，可以简化写入流的操作，
// 通过for（）循序服务器将数据发送的arrayListSocket集合中所有客服端
for (int i = 0; i < arrayListSocket.size(); i++) {
Socket client = arrayListSocket.get(i);
PrintWriter pout = new PrintWriter(client.getOutputStream(), true);
pout.println(line);
}
}

} catch (IOException e) {
System.out.println("接受:" + s.getInetAddress() + " 信息失败");
e.printStackTrace();
}
}

}

public static void main(String[] args) throws Exception, IOException {
// 创建服务器对象
new TCPServer();

}
}

LoginFrame：

import java.awt.BorderLayout;
import java.awt.GridLayout;
import java.awt.Toolkit;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;

import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JPasswordField;
import javax.swing.JTextField;

public class LoginFrame extends JFrame implements ActionListener{
public LoginFrame() {
this.setTitle("注册");
JLabel jl=new JLabel("请输入你的账号:");
JTextField jf=new JTextField(20);
JPanel jp=new JPanel(new GridLayout(3, 1));
JButton jb=new JButton("确认");
JButton jb2=new JButton("返回");
this.setSize(150, 150);
this.setResizable(false);
JLabel jl2=new JLabel("请输入你的密码:");
JPasswordField jw=new JPasswordField(20);
jp.add(jf);
jp.add(jl2);
jp.add(jw);
this.add(jl,BorderLayout.NORTH);
this.add(jp, BorderLayout.CENTER);
JPanel jp2=new JPanel();
jp2.add(jb);
jp2.add(jb2);
this.add(jp2, BorderLayout.SOUTH);
Toolkit tk = Toolkit.getDefaultToolkit();
int swidth = tk.getScreenSize().width;
int sheight = tk.getScreenSize().height;
this.setLocation((swidth - 150) / 2, (sheight - 150) / 2);
this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
this.setVisible(true);

jb.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent arg0) {
int count=0;
String text = jf.getText();
String password = new String(jw.getPassword());
BufferedReader br = null;
BufferedWriter bw=null;
BufferedReader br2 = null;
try {
br = new BufferedReader(new InputStreamReader(new FileInputStream("ss.txt")));
String string = null;
while ((string = br.readLine()) != null) {
String[] split = string.split(",");
if (split[0].equals(text) && split[1].equals(password)) {
JOptionPane.showMessageDialog(LoginFrame.this, "已存在");
count++;
}
}
if(count==0)
{
String string2=null;
br2 = new BufferedReader(new InputStreamReader(new FileInputStream("ss.txt")));
while((string2=br.readLine())==null)
{
bw=new BufferedWriter(new FileWriter("ss.txt",true));
String s=text+","+password;
bw.write(s+"\r\n");
bw.flush();
JOptionPane.showMessageDialog(LoginFrame.this, "注册成功");
}
}
} catch (Exception e1) {
e1.printStackTrace();
} finally {
try {
if (br != null)
br.close();
} catch (IOException e1) {
e1.printStackTrace();
}

}
}
});
jb2.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent arg0) {
LoginFrame.this.setVisible(false);
MainFrame m=new MainFrame();
}
});
}

@Override
public void actionPerformed(ActionEvent arg0) {

}
}

MainFrame：

import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.*;
import javax.swing.*;

//去掉默认布局管理器:JFrame jf = new JFrame("窗口");jf.setLayout(null);
public class MainFrame extends JFrame implements ActionListener {

public MainFrame() throws HeadlessException {
this.setTitle("窗口");
JPanel j1 = new JPanel(new GridLayout(2, 2));
JLabel jl1 = new JLabel(" 用户账号");
JLabel jl2 = new JLabel(" 用户密码");
JTextField jf1 = new JTextField(10);
JPasswordField jp = new JPasswordField(10);
j1.add(jl1);
j1.add(jf1);
j1.add(jl2);
j1.add(jp);
JLabel jl3 = new JLabel(new ImageIcon("img/a.jpg"));
this.add(jl3, BorderLayout.NORTH);
this.add(j1, BorderLayout.CENTER);
this.setSize(500, 500);
this.setResizable(false);
JButton jb = new JButton("提交");
JButton jb2 = new JButton("注册");
JButton jb3 = new JButton("忘记密码？");
JPanel jp2 = new JPanel();
jp2.add(jb);
jp2.add(jb2);
jp2.add(jb3);
this.add(jp2, BorderLayout.SOUTH);

Toolkit tk = Toolkit.getDefaultToolkit();
int swidth = tk.getScreenSize().width;
int sheight = tk.getScreenSize().height;
this.setLocation((swidth - 500) / 2, (sheight - 500) / 2);
this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
this.setVisible(true);
this.pack();

jb.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
int count = 0;
Object source = e.getSource();
String text = jf1.getText();
String password = new String(jp.getPassword());
int confirmDialog = JOptionPane.showConfirmDialog(MainFrame.this, "是否确认登陆");
if (confirmDialog == JOptionPane.YES_OPTION) {
BufferedReader br = null;
try {
br = new BufferedReader(new InputStreamReader(new FileInputStream("ss.txt")));
String string = null;
while ((string = br.readLine()) != null) {
String[] split = string.split(",");
if (split[0].equals(text) && split[1].equals(password)) {
JOptionPane.showMessageDialog(MainFrame.this, "登陆成功");
count++;
MainFrame.this.setVisible(false);
TCPServer t=new TCPServer();
}
}
if (count == 0) {
JOptionPane.showMessageDialog(MainFrame.this, "请先注册");
}
} catch (Exception e1) {
e1.printStackTrace();
} finally {
try {
if (br != null)
br.close();
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
}
});
jb2.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
Object source = e.getSource();
int confirmDialog = JOptionPane.showConfirmDialog(MainFrame.this, "是否确认注册");
if (confirmDialog == JOptionPane.YES_OPTION) {
MainFrame.this.setVisible(false);
LoginFrame l = new LoginFrame();
}
}
});
jb3.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent arg0) {
MainFrame.this.setVisible(false);
MissFrame m = new MissFrame();
}
});
}

public static void main(String[] args) {
MainFrame m = new MainFrame();

}

@Override
public void actionPerformed(ActionEvent arg0) {

}

MissFrame：

public class MissFrame extends JFrame implements ActionListener{
public MissFrame() {
JLabel jl=new JLabel("请输入你的账号:");
JTextField jf=new JTextField(20);
JPanel jp=new JPanel(new GridLayout(2, 1));
JButton jb=new JButton("确认");
JButton jb2=new JButton("返回");
this.setTitle("找回密码");
this.setSize(150, 150);
this.setResizable(false);
JTextArea ja=new JTextArea(1,20);
ja.setEditable(false);
jp.add(jf);
jp.add(ja);
this.add(jl,BorderLayout.NORTH);
this.add(jp, BorderLayout.CENTER);
JPanel jp2=new JPanel();
jp2.add(jb);
jp2.add(jb2);
this.add(jp2, BorderLayout.SOUTH);
Toolkit tk = Toolkit.getDefaultToolkit();
int swidth = tk.getScreenSize().width;
int sheight = tk.getScreenSize().height;
this.setLocation((swidth - 150) / 2, (sheight - 150) / 2);
this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
this.setVisible(true);

jb.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent arg0) {
String text = jf.getText();
BufferedReader br = null;
int count=0;
try {
br = new BufferedReader(new InputStreamReader(new FileInputStream("ss.txt")));
String string = null;
while ((string = br.readLine()) != null) {
String[] split = string.split(",");
if (split[0].equals(text)) {
ja.append(split[1]);
JOptionPane.showMessageDialog(MissFrame.this, "成功");
count++;
}
}
if(count==0)
{
JOptionPane.showMessageDialog(MissFrame.this, "请先注册");
}
} catch (Exception e1) {
e1.printStackTrace();
} finally {
try {
if (br != null)
br.close();
} catch (IOException e1) {
e1.printStackTrace();
}

}
}
});
jb2.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent arg0) {
MissFrame.this.setVisible(false);
MainFrame m=new MainFrame();
}
});
}

@Override
public void actionPerformed(ActionEvent arg0) {

}
}

ReciveThread：

import java.io.*;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.Date;

import javax.swing.JTextArea;
import javax.swing.JTextField;

public class ReciveThread extends Thread {
private Socket recive;
private JTextArea ja1;
private JTextField jf;
public ReciveThread(Socket recive, JTextArea ja1, JTextField jf) {
this.recive = recive;
this.ja1 = ja1;
this.jf = jf;
}
@Override
public void run() {
BufferedReader br = null;
try {
while (true) {
InputStream stream = recive.getInputStream();
jf.setText(recive.getInetAddress().toString());
br = new BufferedReader(new InputStreamReader(stream));
String string = null;
while ((string = br.readLine()) != null) {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
String format = sdf.format(new Date());
ja1.append(format+"\n"+string+"\n");
}
}
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
if (br != null) {
br.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if (recive != null) {
recive.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}

客户端：

TCPClient：

import java.awt.BorderLayout;
import java.awt.FlowLayout;
import java.awt.Toolkit;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import java.awt.event.KeyListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.Date;

public class TCPClient {

static JFrame f;
static JButton send;
static JButton clear;
static JButton close;
static JTextField name;
static JTextField sendjf;
static JTextArea messageArea;
static Socket s;

public static void main(String[] args) {

connetServer();
new setMenu(s);
new Thread(new recvMsg(s)).start();
}

private static void connetServer() {
try {
s = new Socket("127.0.0.1", 30001);
} catch (Exception e) {
System.out.println("客户端连接服务器失败");
e.printStackTrace();
}
}
}

class recvMsg implements Runnable {
private Socket s;
private JTextArea message;

recvMsg(Socket s) {
this.s = s;
this.message = setMenu.messageArea;
}

@Override
public void run() {
BufferedReader bufIn = null;
while (true) {
try {
bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
} catch (IOException e1) {
System.out.println("接收信息失败");
e1.printStackTrace();
}

try {
String recvMsg = bufIn.readLine();
SimpleDateFormat sdf = new SimpleDateFormat("YYYY-MM-dd:hh-mm-ss");
String format = sdf.format(new Date());
message.append(format + "\n" + recvMsg + "\r\n");
setMenu.messageArea.setCaretPosition(setMenu.messageArea.getDocument().getLength());
} catch (IOException e) {
e.printStackTrace();
}
}
}
}

/**
* 创建GUI界面的类
*/
class setMenu {
static JFrame f;
static JButton send;
static JButton clear;
static JButton close;
static JTextField name;
static JTextField sendjf;
static JTextArea messageArea;
Socket s;

setMenu(Socket s) {
this.s = s;
createMenu();
someListener();
}

private void someListener() {
send.addActionListener(new SendMsg3(s));
close.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
System.exit(1);
}
});
sendjf.addKeyListener(new SendMsg3(s));
clear.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
sendjf.setText("");
}
});
messageArea.addKeyListener(new KeyAdapter() {
@Override
public void keyTyped(KeyEvent e) {
}
});
}

private void createMenu() {
f = new JFrame("I am 扣扣");
Toolkit tk = Toolkit.getDefaultToolkit();
int swidth = tk.getScreenSize().width;
int sheight = tk.getScreenSize().height;
f.setLocation((swidth - 500) / 2, (sheight - 500) / 2);
f.setBounds(50, 50, 700, 600);
JPanel panel = new JPanel();
JLabel label = new JLabel("名字：", JLabel.RIGHT);
name = new JTextField(20);
panel.add(label, JPanel.RIGHT_ALIGNMENT);
panel.add(name, JPanel.RIGHT_ALIGNMENT);

messageArea = new JTextArea("", 25, 50);
messageArea.setEditable(false);

JLabel label_send = new JLabel("发送内容：");
sendjf = new JTextField(30);

JPanel button = new JPanel(new FlowLayout());
send = new JButton("发送");
clear = new JButton("清除");
close = new JButton("关闭");
button.add(label_send);
button.add(sendjf);
button.add(send);
button.add(clear);
button.add(close);

JScrollPane jsp=new JScrollPane(messageArea);
JPanel jpj=new JPanel();
jpj.add(jsp);

f.add(panel, BorderLayout.NORTH);
f.add(jpj, BorderLayout.CENTER);
f.add(button, BorderLayout.SOUTH);
f.setVisible(true);

}

class SendMsg3 implements ActionListener, KeyListener {
Socket s;

SendMsg3(Socket s) {
this.s = s;
}

@Override
public void keyTyped(KeyEvent e) {
}

@Override
public void keyPressed(KeyEvent e) {
// VK_ENTER回车键的虚拟键
if (e.getKeyCode() == KeyEvent.VK_ENTER) {
sendMsg();
}

}

@Override
public void keyReleased(KeyEvent e) {

}

@Override
public void actionPerformed(ActionEvent e) {
sendMsg();

}

private void sendMsg() {
if (name.getText().isEmpty()) {
JOptionPane.showMessageDialog(null, "请取别名！");
}

String line = name.getText() + ": " + sendjf.getText();

try {
if (!line.isEmpty()) {
// PrintWriter是可以自带刷新缓存工作，可以简化写入流的操作，
PrintWriter pout = new PrintWriter(s.getOutputStream(), true);
pout.println(line);
System.out.print("input:" + line);
sendjf.setText("");
messageArea.setCaretPosition(messageArea.getDocument().getLength());
} else {
System.out.println("发送数据为空，请重新输入");

JOptionPane.showMessageDialog(null, "发送数据为空，请重新输入！");
}

} catch (Exception e1) {
System.out.println("发送失败");
e1.printStackTrace();
}
}
}
}

LoginFrame：

}
}
});
jb2.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent arg0) {
LoginFrame.this.setVisible(false);
MainFrame m=new MainFrame();
}
});
}

@Override
public void actionPerformed(ActionEvent arg0) {

}
}

MainFrame：

import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.*;
import javax.swing.*;

//去掉默认布局管理器:JFrame jf = new JFrame("窗口");jf.setLayout(null);
public class MainFrame extends JFrame implements ActionListener {

public static void main(String[] args) {
MainFrame m = new MainFrame();

}

@Override
public void actionPerformed(ActionEvent arg0) {

}

MissFrame：

jb.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent arg0) {
   String text = jf.getText();
   BufferedReader br = null;
   int count=0;
try {
br = new BufferedReader(new InputStreamReader(new FileInputStream("ss.txt")));
String string = null;
while ((string = br.readLine()) != null) {
String[] split = string.split(",");
if (split[0].equals(text)) {
ja.append(split[1]);
JOptionPane.showMessageDialog(MissFrame.this, "成功");
count++;
}
}
if(count==0)
{
JOptionPane.showMessageDialog(MissFrame.this, "请先注册");
}
} catch (Exception e1) {
e1.printStackTrace();
} finally {
try {
if (br != null)
br.close();
} catch (IOException e1) {
e1.printStackTrace();
}

}
}
});
jb2.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent arg0) {
MissFrame.this.setVisible(false);
MainFrame m=new MainFrame();
}
});
}

@Override
public void actionPerformed(ActionEvent arg0) {

}
}

ReciveThread：

import java.io.*;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.Date;

import javax.swing.JTextArea;
import javax.swing.JTextField;

Java TCP 群聊相关推荐

Java NIO群聊系统
实例要求: 1.编写一个 NIO 群聊系统,实现服务器端和客户端之间的数据简单通讯(非阻塞) 2.实现多人群聊 3.服务器端:可以监测用户上线,离线,并实现消息转发功能 4.客户端:通过 Channe ...
Java MulticastSocket 群聊应用程序
在这篇文章中,讨论了一个使用 MulticastSocket (Java Platform SE 7) 类的群聊应用程序.MulticastSocket 是一个 (UDP) DatagramSocke ...
java socket群聊_java socket来实现私聊和群聊-简易版
public class MyServer { List list=new ArrayList(); public static void main(String[] args) { try { // ...
Java网络编程：TCP实现群聊私聊代码
Java网络编程:TCP实现群聊&私聊代码和上一篇博客差不多,只不过是在群里的基础之上增加了私聊的功能,我们约定,私聊格式为:@xxx:msg 如何实现私聊呢,加入客户端c给服务器发送消息, ...
Java如何实现不同局域网TCP通信+群聊（云服务器实现）
最近在CSDN上学习了Socket通信群聊的方法,就觉得这样就可以实现QQ的样子了.然后让女朋友用电脑试了一下,运行用户端代码,发现连连接到服务器都做不到.后来经过自己的研究,实现了QQ群聊的功能,后 ...
Java用TCP手写聊天室可以私聊版加群聊版
一:引言想要私聊必须有规定的格式:@名字:要说的话二:上码 1.服务端 package com.wyj.talkhome; /** * 实现一个用户可以接发多条消息 * * */ import j ...
Java使用TCP实现群聊聊天室（多线程和tcp的使用）
一:引言: 显示结果在控制台显示,未能实现图形界面的结合二:上码 1.服务端 package com.wyj.talkhome; /** * 实现一个用户可以接发多条消息 * * */ import ...
TCP多人聊天程序Java实现（群聊，私聊，在线用户，踢出用户）
本程序在程序 https://blog.csdn.net/joffy/article/details/18079331 的基础是上添加了私聊,踢出用户两个功能. 由客户端和服务器端构成程序,程序借助J ...
Java项目模拟QQ群聊和私聊（网络编程+多线程）
[文末获取资源] 前几天学习了多线程,最近在学习网络编程,了解了UDP之后又学习了TCP,听一下大佬说,要看看你这两个东西掌握的怎么样,最好的办法就是写一个模拟QQ群聊和私聊,经过这几天的学习,以及不 ...

Java TCP 群聊

Java TCP 群聊相关推荐

最新文章

热门文章