群聊私聊java源代码 java交流微信群

java 聊天室 源代码

【ClientSocketDemo.java 客户端Java源代码】

成都创新互联是一家专业从事成都网站设计、网站建设的网络公司。作为专业网站制作公司,成都创新互联依托的技术实力、以及多年的网站运营经验,为您提供专业的成都网站建设、全网营销推广及网站设计开发服务！

import java.net.*;

import java.io.*;

public class ClientSocketDemo

{

//声明客户端Socket对象socket

Socket socket = null;

//声明客户器端数据输入输出流

DataInputStream in;

DataOutputStream out;

//声明字符串数组对象response，用于存储从服务器接收到的信息

String response[];

//执行过程中，没有参数时的构造方法，本地服务器在本地，取默认端口10745

public ClientSocketDemo()

{

try

{

//创建客户端socket，服务器地址取本地，端口号为10745

socket = new Socket("localhost",10745);

//创建客户端数据输入输出流，用于对服务器端发送或接收数据

in = new DataInputStream(socket.getInputStream());

out = new DataOutputStream(socket.getOutputStream());

//获取客户端地址及端口号

String ip = String.valueOf(socket.getLocalAddress());

String port = String.valueOf(socket.getLocalPort());

//向服务器发送数据

out.writeUTF("Hello Server.This connection is from client.");

out.writeUTF(ip);

out.writeUTF(port);

//从服务器接收数据

response = new String[3];

for (int i = 0; i response.length; i++)

{

response[i] = in.readUTF();

System.out.println(response[i]);

}

}

catch(UnknownHostException e){e.printStackTrace();}

catch(IOException e){e.printStackTrace();}

}

//执行过程中，有一个参数时的构造方法，参数指定服务器地址，取默认端口10745

public ClientSocketDemo(String hostname)

{

try

{

//创建客户端socket，hostname参数指定服务器地址，端口号为10745

socket = new Socket(hostname,10745);

in = new DataInputStream(socket.getInputStream());

out = new DataOutputStream(socket.getOutputStream());

String ip = String.valueOf(socket.getLocalAddress());

String port = String.valueOf(socket.getLocalPort());

out.writeUTF("Hello Server.This connection is from client.");

out.writeUTF(ip);

out.writeUTF(port);

response = new String[3];

for (int i = 0; i response.length; i++)

{

response[i] = in.readUTF();

System.out.println(response[i]);

}

}

catch(UnknownHostException e){e.printStackTrace();}

catch(IOException e){e.printStackTrace();}

}

//执行过程中，有两个个参数时的构造方法，第一个参数hostname指定服务器地址

//第一个参数serverPort指定服务器端口号

public ClientSocketDemo(String hostname,String serverPort)

{

try

{

socket = new Socket(hostname,Integer.parseInt(serverPort));

in = new DataInputStream(socket.getInputStream());

out = new DataOutputStream(socket.getOutputStream());

String ip = String.valueOf(socket.getLocalAddress());

String port = String.valueOf(socket.getLocalPort());

out.writeUTF("Hello Server.This connection is from client.");

out.writeUTF(ip);

out.writeUTF(port);

response = new String[3];

for (int i = 0; i response.length; i++)

{

response[i] = in.readUTF();

System.out.println(response[i]);

}

}

catch(UnknownHostException e){e.printStackTrace();}

catch(IOException e){e.printStackTrace();}

}

public static void main(String[] args)

{

String comd[] = args;

if(comd.length == 0)

{

System.out.println("Use localhost(127.0.0.1) and default port");

ClientSocketDemo demo = new ClientSocketDemo();

}

else if(comd.length == 1)

{

System.out.println("Use default port");

ClientSocketDemo demo = new ClientSocketDemo(args[0]);

}

else if(comd.length == 2)

{

System.out.println("Hostname and port are named by user");

ClientSocketDemo demo = new ClientSocketDemo(args[0],args[1]);

}

else System.out.println("ERROR");

}

}

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

【ServerSocketDemo.java 服务器端Java源代码】

import java.net.*;

import java.io.*;

public class ServerSocketDemo

{

//声明ServerSocket类对象

ServerSocket serverSocket;

//声明并初始化服务器端监听端口号常量

public static final int PORT = 10745;

//声明服务器端数据输入输出流

DataInputStream in;

DataOutputStream out;

//声明InetAddress类对象ip，用于获取服务器地址及端口号等信息

InetAddress ip = null;

//声明字符串数组对象request，用于存储从客户端发送来的信息

String request[];

public ServerSocketDemo()

{

request = new String[3]; //初始化字符串数组

try

{

//获取本地服务器地址信息

ip = InetAddress.getLocalHost();

//以PORT为服务端口号，创建serverSocket对象以监听该端口上的连接

serverSocket = new ServerSocket(PORT);

//创建Socket类的对象socket，用于保存连接到服务器的客户端socket对象

Socket socket = serverSocket.accept();

System.out.println("This is server:"+String.valueOf(ip)+PORT);

//创建服务器端数据输入输出流，用于对客户端接收或发送数据

in = new DataInputStream(socket.getInputStream());

out = new DataOutputStream(socket.getOutputStream());

//接收客户端发送来的数据信息，并显示

request[0] = in.readUTF();

request[1] = in.readUTF();

request[2] = in.readUTF();

System.out.println("Received messages form client is:");

System.out.println(request[0]);

System.out.println(request[1]);

System.out.println(request[2]);

//向客户端发送数据

out.writeUTF("Hello client!");

out.writeUTF("Your ip is:"+request[1]);

out.writeUTF("Your port is:"+request[2]);

}

catch(IOException e){e.printStackTrace();}

}

public static void main(String[] args)

{

ServerSocketDemo demo = new ServerSocketDemo();

}

}

java 实现群聊和 私聊 群聊会实现 但是私聊？

服务器 端 使用个链表把在线用户账号和他对应的链接保存起来。例如 soket。

之后 定义一个协议，

在 客户端发出来的 聊天信息前面添加一个头。

例如，1表示群聊，2表示私聊，3表示添加好友，等等。每一个行为对应一个编码超过10个可以使用字母。

群聊的话，没什么好说，每个人发一个；

私聊，那么接下来的一个字符可以表示，私聊对象的账户名 的长度，比如 tom的 长度就是3，

之后，根据长度，截取 第3到第5个字符，截取到 此次 私聊信息是发送给 tom 的。

这条发送给服务器，希望他转发给tom的 消息就应该是

"23tom你好！"

之后去链表里面找tom 的soket 链接。打开他的 输出流，给他传送 聊天信息。

欢迎追问。

用Java实现一个人和几个不同的人私聊，用Socket实现

package API_Day09;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

import java.util.Scanner;

/**

* 控制台聊天程序

* 客户端应用程序

* @author Jacob

*

*/

public class chatClient

{

//客户端用于与服务端连接的Socket

private Socket clientSocket;

/**

* 构造方法，客户端初始化

*/

public chatClient()

{

try

{

/*

* socket(String host, int port)

* 地址： IP地址，用来定位网络上的计算机

* 端口： 用来找到远端计算机上用来连接的服务端应用程序

*/

clientSocket = new Socket("localhost",12580);

}

catch (Exception e)

{

e.printStackTrace();

}

}

/**

* 客户端昵称验证方法

* @param 为Scanner

*/

private void inputNickName(Scanner scan) throws Exception

{

String nickName = null;

//创建输出流

PrintWriter pw = new PrintWriter(

new OutputStreamWriter(clientSocket.getOutputStream(),

"UTF-8"),true);

//创建输入流

BufferedReader br = new BufferedReader(

new InputStreamReader(

clientSocket.getInputStream(),"UTF-8"));

while(true)

{

System.out.println("请创建您的昵称：");

nickName = scan.nextLine();

if (nickName.trim().equals(""))

{

System.out.println("昵称不得为空");

}

else

{

pw.println(nickName);

String pass = br.readLine();

if(pass!=null!pass.equals("OK"))

{

System.out.println("昵称已经被占用，请更换！");

}

else

{

System.out.println("你好！"+nickName+"可以开始聊天了");

break;

}

}

}

}

/*

* 客户端启动的方法

*/

public void start()

{

try

{

/*

* 创建Scanner，读取用户输入内容

* 目的是设置客户端的昵称

*/

Scanner scanner = new Scanner(System.in);

inputNickName(scanner);

/*

* 将用于接收服务器端发送过来的信息的线程启动

*/

Runnable run = new GetServerMsgHandler();

Thread t = new Thread(run);

t.start();

/*

* 建立输出流，给服务端发信息

*/

OutputStream os = clientSocket.getOutputStream();

OutputStreamWriter osw = new OutputStreamWriter(os,"UTF-8");

PrintWriter pw = new PrintWriter(osw,true);

while(true)

{

pw.println(scanner.nextLine());

}

}

catch(Exception e)

{

e.printStackTrace();

}

finally

{

if(clientSocket !=null)

{

try

{

clientSocket.close();

}

catch(IOException e)

{

e.printStackTrace();

}

}

}

}

/**

* 该线程体用来循环读取服务端发送过来的信息

* 并输出到客户端的控制台

* @param args

*/

class GetServerMsgHandler implements Runnable

{

@Override

public void run()

{

try

{

InputStream is = clientSocket.getInputStream();

InputStreamReader isr = new InputStreamReader(is,"UTF-8");

BufferedReader br = new BufferedReader(isr);

String msgString = null;

while((msgString = br.readLine())!= null)

{

System.out.println("服务端提示："+ msgString);

}

}

catch(Exception e)

{

e.printStackTrace();

}

}

}

public static void main(String[] args)

{

chatClient client = new chatClient();

client.start();

}

}

package API_Day09;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.HashMap;

import java.util.Map;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

/**

* 控制台聊天程序

* 服务端应用程序

* @author Jacob

*

*/

public class chatServer

{

/**

* ServerSocket 是运行在服务端的Socket

* 用来监听端口，等待客户端的连接，

* 一旦连接成功就会返回与该客户端通信的Socket

*/

private ServerSocket serverSocket;

/**

* 创建线程池来管理客户端的连接线程

* 避免系统资源过度浪费

*/

private ExecutorService threadPool;

/**

* 该属性用来存放客户端之间私聊的信息

*/

private MapString,PrintWriter allOut;

/**

* 构造方法，服务端初始化

*/

public chatServer()

{

try

{

/*

* 创建ServerSocket，并申请服务端口

* 将来客户端就是通过该端口连接服务端程序的

*/

serverSocket = new ServerSocket(12580);

/*

* 初始化Map集合，存放客户端信息

*/

allOut = new HashMapString, PrintWriter();

/*

* 初始化线程池，设置线程的数量

*/

threadPool = Executors.newFixedThreadPool(10);

/*

* 初始化用来存放客户端输出流的集合，

* 每当一个客户端连接，就会将该客户端的输出流存入该集合；

* 每当一个客户端断开连接，就会将集合中该客户端的输出流删除；

* 每当转发一条信息，就要遍历集合中的所有输出流(元素)

* 因此转发的频率高于客户端登入登出的频率，

* 还是应该使用ArrayList来存储元素，仅限群聊，私聊不行

* allOut = new ArrayListPrintWriter();

*/

}

catch (Exception e)

{

e.printStackTrace();

}

}

/*

* 将客户端的信息以Map形式存入集合中

*/

private void addOut(String key,PrintWriter value)

{

synchronized(this)

{

allOut.put(key, value);

}

}

/*

* 将给定的输出流从共享集合中删除

* 参数为客户端nickName,作为Map的key键

*/

private synchronized void removeOut(String key)

{

allOut.remove(key);

System.out.println("当前在线人数为："+ allOut.size());

}

/*

* 将给定的消息转发给所有客户端

*/

private synchronized void sendMsgToAll(String message)

{

for(PrintWriter out: allOut.values())

{

out.println(message);

System.out.println("当前在线人数为："+ allOut.size());

}

}

/*

* 将给定的消息转发给私聊的客户端

*/

private synchronized void sendMsgToPrivate(String nickname,String message)

{

PrintWriter pw = allOut.get(nickname); //将对应客户端的聊天信息取出作为私聊内容发送出去

if(pw!=null)

{

pw.println(message);

System.out.println("当前在线私聊人数为："+ allOut.size());

}

}

/**

* 服务端启动的方法

*/

public void start()

{

try

{

while(true)

{

/*

* 监听10086端口

*/

System.out.println("等待客户端连接... ... ");

/*

* Socket accept() 这是一个阻塞方法，会一直在10086端口进行监听

* 直到一个客户端连接上，此时该方法会将与这个客户端进行通信的Socket返回

*/

Socket socket = serverSocket.accept();

System.out.println("客户端连接成功！ ");

/*

* 启动一个线程，由线程来处理客户端的请求，这样可以再次监听

* 下一个客户端的连接了

*/

Runnable run = new GetClientMsgHandler(socket);

threadPool.execute(run); //通过线程池来分配线程

}

}

catch(Exception e)

{

e.printStackTrace();

}

}

/**

* 该线程体用来处理给定的某一个客户端的消息，循环接收客户端发送

* 的每一个字符串，并输出到控制台

* @author Jacob

*

*/

class GetClientMsgHandler implements Runnable

{

/*

* 该属性是当前线程处理的具体的客户端的Socket

* @see java.lang.Runnable#run()

*/

private Socket socket;

/*

* 获取客户端的地址信息

* private String hostIP;

*/

/*

* 获取客户端的昵称

*/

private String nickName;

/*

* 创建构造方法

*/

public GetClientMsgHandler(Socket socket)

{

this.socket = socket;

/*

* 获取远端客户的Ip地址信息

* 保存客户端的IP地址字符串

* InetAddress address = socket.getInetAddress();

* hostIP = address.getHostAddress();

*/

}

/*

* 创建内部类来获取昵称

*/

private String getNickName() throws Exception

{

try

{

//服务端的输入流读取客户端发送来的昵称输出流

InputStream iin = socket.getInputStream();

InputStreamReader isr =

new InputStreamReader(iin,"UTF-8");

BufferedReader bReader = new BufferedReader(isr);

//服务端将昵称验证结果通过自身的输出流发送给客户端

OutputStream out = socket.getOutputStream();

OutputStreamWriter iosw =

new OutputStreamWriter(out,"UTF-8");

PrintWriter ipw = new PrintWriter(iosw,true);

//读取客户端发来的昵称

String nameString = bReader.readLine();

while(true)

{

if(nameString.trim().length()==0)

{

ipw.println("FAIL");

}

if(allOut.containsKey(nameString))

{

ipw.println("FAIL");

}

else

{

ipw.println("OK");

return nameString;

}

nameString = bReader.readLine();

}

}

catch(Exception e)

{

throw e;

}

}

@Override

public void run()

{

PrintWriter pw = null;

try

{

/*

* 通过客户端的Socket获取客户端的输出流

* 用来将消息发送给客户端

*/

OutputStream os = socket.getOutputStream();

OutputStreamWriter osw = new OutputStreamWriter(os,"UTF-8");

pw = new PrintWriter(osw,true);

/*

* 将客户昵称和其所说的话作为元素存入共享集合HashMap中

*/

nickName = getNickName();

addOut(nickName, pw);

Thread.sleep(100);

/*

* 服务端通知所有客户端，某用户登录

*/

sendMsgToAll("[系统通知]：欢迎**"+nickName+"**登陆聊天室!");

/*

* 通过客户端的Socket获取输入流

* 读取客户端发送来的信息

*/

InputStream is = socket.getInputStream();

InputStreamReader isr = new InputStreamReader(is,"UTF-8");

BufferedReader br = new BufferedReader(isr);

String msgString = null;

while((msgString = br.readLine())!=null)

{

//验证是否是私聊

if(msgString.startsWith("@"))

{

/*

* 私聊格式：@昵称：内容

*/

int index = msgString.indexOf(":");

if(index =0)

{

//获取昵称

String name = msgString.substring(1,index);

String info = msgString.substring(index+1,msgString.length());

info = nickName + "对你说："+ info;

//将私聊信息发送出去

sendMsgToPrivate(name, info);

//服务端不在广播私聊的信息

continue;

}

}

/*

* 遍历所有输出流，将该客户端发送的信息转发给所有客户端

*/

System.out.println(nickName+"说："+ msgString);

sendMsgToAll(nickName+"说："+ msgString);

}

}

catch (Exception e)

{

/*

* 因为Win系统用户的客户端断开连接后，br.readLine()方法读取

* 不到信息就会抛出异常，而Linux系统会持续发送null；

* 因此这里就不在将捕获的异常抛出了。

*/

}

finally

{

/*

* 当执行到此处时，说明客户端已经与服务端断开连接

* 则将该客户端存在共享集合中的输出流删除

*/

removeOut(nickName);

/*

* 通知所有客户端，某某客户已经下线

*/

sendMsgToAll("[系统通知]："+nickName + "已经下线了。");

/*

* 关闭socket，则通过Socket获取的输入输出流也一同关闭了

*/

if(socket!=null)

{

try

{

socket.close();

}

catch(IOException e)

{

e.printStackTrace();

}

}

}

}

}

public static void main(String[] args)

{

chatServer server = new chatServer();

server.start();

}

}

我的作业，供你参考