java实现一个简单TCPSocket聊天室功能分享

2016-7-29 15:37| 发布者: zhangjf| 查看: 776| 评论: 0

摘要: 本文实例为大家分享了java实现TCPSocket聊天室功能的相关代码，供大家参考，具体内容如下 1.TCPserver.java import java.net.*;import java.io.*;import java.util.*;import java.util.concurrent.*;public class T ...

本文实例为大家分享了java实现TCPSocket聊天室功能的相关代码，供大家参考，具体内容如下

1.TCPserver.java

import java.net.*;
import java.io.*;
import java.util.*;
import java.util.concurrent.*;
public class TCPserver{
private static final int SERVERPORT = 8888;
private ServerSocket MyServer = null;
private List<Socket> Clients = new ArrayList<Socket>();
private ExecutorService mExecutorService;
public TCPserver(){
try{
MyServer = new ServerSocket(SERVERPORT);
mExecutorService = Executors.newCachedThreadPool();
System.out.println("start:");
Socket MySocket = null;
while(true){
MySocket = MyServer.accept();
Clients.add(MySocket);
mExecutorService.execute(new ThreadServer(MySocket));
}
}catch(Exception e){
e.printStackTrace();
System.exit(0);
}
}
class ThreadServer implements Runnable{
private Socket msocket=null;
private BufferedReader in= null;
private PrintWriter out = null;
private String mStrMSG = null;
public ThreadServer(Socket socket) {
try{
this.msocket=socket;
in = new BufferedReader(new InputStreamReader(msocket.getInputStream(), "GB2312"));
mStrMSG = "user:" + msocket.getInetAddress() + " come total:" + Clients.size();
SendMassage();
}catch(IOException e){
System.out.println("erorr");
System.exit(0);
}
}
private void SendMassage(){
try{
System.out.println(mStrMSG);
for(Socket MySocket:Clients)
{
out = new PrintWriter(new OutputStreamWriter(MySocket.getOutputStream(),"GB2312"),true);
out.println(mStrMSG);
}
}catch(IOException e){
System.out.println("erorr");
System.exit(0);
}
}
public void run(){
try{
while((mStrMSG = in.readLine())!=null){
if(mStrMSG.trim().equals("exit")){
Clients.remove(msocket);
in.close();
out.close();
mStrMSG = "user:" + msocket.getInetAddress() + " exit tatal:" + Clients.size(); ;
msocket.close();
SendMassage();
break;
}
else{
mStrMSG = msocket.getInetAddress()+":" + mStrMSG;
SendMassage();
}
}
}catch(IOException e){
System.out.println("erorr");
System.exit(0);
}
}
}
public static void main(String[] args){
new TCPserver();
}
}

复制代码

2.TCPclient.java

import java.net.*;
import java.io.*;
import java.util.concurrent.*;
public class TCPclient {
private static final int PORT = 8888;
private Socket Client = null;
private BufferedReader sin = null;
private ExecutorService mExecutorService;
public TCPclient(){
try{
Client = new Socket("120.27.126.174",PORT);
sin = new BufferedReader(new InputStreamReader(Client.getInputStream(),"GB2312"));
mExecutorService = Executors.newCachedThreadPool();
mExecutorService.execute(new ThreadClient(Client));
String msg = null;
while((msg = sin.readLine()) != null) {
System.out.println(msg);
}
}catch(IOException e){
System.out.println(e.getMessage());
}
}
class ThreadClient extends Thread{
private Socket mSocket = null;
private String msg = null;
BufferedReader in = null;
PrintWriter out = null;
public ThreadClient(Socket socket){
this.mSocket = socket;
}
public void run(){
try{
in = new BufferedReader(new InputStreamReader(System.in));
out = new PrintWriter(new OutputStreamWriter(mSocket.getOutputStream(), "GB2312"), true);
while(true){
msg = in.readLine();
out.println(msg);
if(msg.trim().equals("exit")){
in.close();
out.close();
mExecutorService.shutdownNow();
break;
}
}
}catch(IOException e){
System.out.println("see you");
System.exit(0);
}
}
}
public static void main(String[] args){
new TCPclient();
}
}

复制代码

以上就是java实现TCPSocket聊天室功能的代码，希望对大家的学习有所帮助。

收藏邀请

上一篇：Java利用HttpClient模拟POST表单操作应用及注意事项下一篇：Java使用cookie显示最近查看过的书

		自动登录	找回密码
密码			立即注册

java实现一个简单TCPSocket聊天室功能分享

最新评论

相关分类