Java使用TCP实现在线聊天的示例代码
客户端的代码：
packagetcp.http;
importjava.io.*;
importjava.net.*;
importjava.util.Scanner;
publicclassClient{
publicstaticvoidmain(String[]args)throwsIOException{
Scannerscanner=newScanner(System.in);
//1.创建Socket
SockettcpClientSocket=newSocket();
//2.TCP要发送消息，必须先建立连接
byte[]IPv4={127,0,0,1};//连接到本机
InetAddressserverAddress=InetAddress.getByAddress(IPv4);
SocketAddressserverSocketAddress=newInetSocketAddress(serverAddress,7777);
tcpClientSocket.connect(serverSocketAddress);//连接上了，（连接过程代码比较长，但是没有什么复杂的，只需要查文档根据函数的构造过程，一步步来写就好了）
while(true){//写个死循环来聊天
Stringrequest=scanner.nextLine();
//通过字节流写入请求
OutputStreamos=tcpClientSocket.getOutputStream();
//通过打印流打印和写入
PrintStreamout=newPrintStream(os,true,"UTF-8");
out.println(request);
//通过字节流读取响应
InputStreamis=tcpClientSocket.getInputStream();
BufferedReaderreader=newBufferedReader(newInputStreamReader(is,"UTF-8"));//通过readLine()来保证每次都能把一句完整的话读完（\r\n是标志）;
Stringresponse=reader.readLine();
System.out.println(""+response);
}
//tcpClientSocket.close();
}
}
服务器端的代码：
packagetcp.threads;
importjava.io.*;
importjava.net.*;
importjava.util.Scanner;
importjava.util.concurrent.*;
publicclassServer{
privatestaticclassTalkRunnableimplementsRunnable{//一个个的工作线程
privateSocketclientSocket;
TalkRunnable(Socketsocket){
this.clientSocket=socket;
}
@Override
publicvoidrun(){
try{
InetAddressclientAddress=clientSocket.getInetAddress();
intclientPort=clientSocket.getPort();
System.out.printf("ID为%s:%d的好友上线了%n",clientAddress.getHostAddress(),clientPort);
//获取字节流
InputStreamis=null;
is=clientSocket.getInputStream();
//字节流转换为字符流
InputStreamReader
isReader=null;
isReader=newInputStreamReader(is,"UTF-8");
//获取输出字节流
OutputStreamos=clientSocket.getOutputStream();
//获取打印流
PrintStreamout=newPrintStream(os,true,"UTF-8");
//获取缓冲字符流
BufferedReaderreader=newBufferedReader(isReader);
while(true){//死循环聊天
Stringline=reader.readLine();
System.out.println("好友说："+line);
Scannerscanner=newScanner(System.in);
Stringresponse=scanner.nextLine();
out.println(response);
}
}catch(IOExceptione){
e.printStackTrace();
}
}
}
publicstaticvoidmain(String[]args)throwsIOException{
//监听连接
ServerSockettcpServerSocket=newServerSocket(7777);
//定义阻塞队列
BlockingQueuequeue=newLinkedBlockingQueue<>();
//创建线程池
ExecutorServicepool=newThreadPoolExecutor(100,100,0,TimeUnit.MILLISECONDS,queue);
while(true){
//TCP要发送消息必须先建立连接
SocketclientSocket=tcpServerSocket.accept();
pool.execute(newTalkRunnable(clientSocket));//有一个客户端连接到服务器，就起一个线程来专门处理这个对话
}
}
}
运行结果：
为什么要使用多线程？
因为单线程会发生阻塞，聊天就进行不下去了。。。
又是自己和自己聊天的一天==，最近好迷TCP和UDP，欢迎各位大佬批评指正呀，一起交流呀!!!啦啦啦
对比这个聊天程序和上一篇用UDP写的聊天程序可以更好的体会TCP和UDP的区别。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。