单聊和群聊

TCP协议单聊
服务端：

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.Vector;
import javax.swing.JFrame;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;

public class fuwuchuangkou extends JFrame {
private JTextArea ta_info;
private ServerSocket server; // 声明ServerSocket对象
private Socket socket; // 声明Socket对象socket
private Vector<Socket> vector = new Vector<Socket>();// 用于存储连接到服务器的客户端套接字对象

public void createSocket() {
try {
server = new ServerSocket(1978);
while (true) {
ta_info.append("等待新客户连接......\n");
socket = server.accept();// 创建套接字对象
vector.add(socket);// 将套接字对象添加到向量对象中
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();// 读取信息
for (Socket s : vector) {// 遍历所有客户端套接字对象
if (s != socket) {// 如果不是发送信息的套接字对象
PrintWriter out = new PrintWriter(s
.getOutputStream(), true);// 创建输出流对象
out.println(info);// 发送信息
out.flush();// 刷新输出缓冲区
}
}
}
} catch (IOException e) {
ta_info.append(socket + "已经退出。\n");
vector.remove(socket);// 移除退出的客户端套接字
}
}
}


public static void main(String args[]) {
fuwuchuangkou frame = new fuwuchuangkou();
frame.setVisible(true);
frame.createSocket();
}

/**
* Create the frame
*/
public fuwuchuangkou() {
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);
}
}

客户端：
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 kehuchuangkou 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 {
kehuchuangkou frame = new kehuchuangkou();
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 kehuchuangkou() { //创建面板
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);

}

}

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 kehu1 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 {
kehuchuangkou frame = new kehuchuangkou();
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 kehu1() { //创建面板
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);

}

}
结果：

UDP协议群聊
服务端：
import java.io.*;
import java.net.*;
import java.util.ArrayList;
public class Server{
public static ServerSocket server_socket;
public static ArrayList<Socket> socketList=new ArrayList<Socket>();
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 st=new 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;i<char_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){
rtn=rtn+(char)(char_src-13);
}else{
break;
}
}
return rtn;
}
}
class ServerBO_Thread extends Thread{
Socket client = null;
ArrayList<Socket> clients;
ServerBO_Thread(Socket s,ArrayList<Socket> ss){//初始化
client=s;
clients=ss;
}
public void run(){
DataInputStream input = null;
DataOutputStream output =null;
try{
input = new DataInputStream(client.getInputStream());
Server bo = new Server();
String receive=null;
String send=null;
while(true){//监视当前客户端有没有发来消息
if(!client.isClosed()){
receive=bo.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();
}
}
}

客户端：

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 People{
//服务端ip
public 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){
People po = new People();
po.start();
}
public void start(){
try{
System.out.println("*******欢迎使用匿名聊天室！**********");
System.out.println("请输入你将要使用的昵称：");
name=sc.nextLine();//获取昵称
socket = new Socket(ip,port);
output=new 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 out=new 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;i<char_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){
rtn=rtn+(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){
output=ot;
input=it;
name=n;
}
public void run(){
People po = new People();
try{
while(true){
String send=sc.nextLine();//获取用户输入
String send2=name+"&"+send;//把聊天内容打包成约定形式
po.encryptWrite(send2,output);
}
}catch(Exception ex){
ex.printStackTrace();
}finally{
System.out.println("sfef");
}
}
结果：