java实现简单TCP聊天程序
作者:yubo_725 时间:2021-09-29 20:18:15
本文实例为大家分享了java实现TCP聊天程序的具体代码,供大家参考,具体内容如下
服务端代码:
package com.test.server;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static void main(String[] args) {
new Server().startServer();
}
public void startServer(){
try {
//服务器在9990端口监听客户端的连接
ServerSocket ss = new ServerSocket(9999);
System.out.println("server is listening...");
while(true){
//阻塞的accept方法,当一个客户端连接上,才会返回Socket对象
Socket s = ss.accept();
System.out.println("a client has connected!");
//开启线程处理通信
new CommunicateThread(s).start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
public class CommunicateThread extends Thread{
Socket socket;
DataInputStream dis;
DataOutputStream dos;
public CommunicateThread(Socket socket){
this.socket = socket;
try {
dis = new DataInputStream(socket.getInputStream());
dos = new DataOutputStream(socket.getOutputStream());
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void run() {
super.run();
//读取客户端发过来的消息
String msg = null;
try {
while((msg = dis.readUTF()) != null){
System.out.println("client send msg :" + msg);
String replyMsg = "server reply : " + msg;
dos.writeUTF(replyMsg);
System.out.println("server reply msg :" + replyMsg);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
客户端代码:
package com.test.client;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.Scanner;
public class Client {
public static void main(String[] args) {
new Client().startClient();
}
public void startClient(){
try {
//连接到服务器
Socket socket = new Socket("localhost", 9999);
DataInputStream dis = new DataInputStream(socket.getInputStream());
DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
Scanner scanner = new Scanner(System.in);
String line = null;
listenServerReply(dis);
while((line = scanner.nextLine()) != null){//读取从键盘输入的一行
dos.writeUTF(line);//发给服务端
System.out.println("client send msg : " + line);
}
} catch (Exception e) {
e.printStackTrace();
}
}
//监听服务端回复的消息
public void listenServerReply(final DataInputStream dis){
new Thread(){
@Override
public void run() {
super.run();
String line = null;
try {
while((line = dis.readUTF()) != null){
System.out.println("client receive msg from server: " + line);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}.start();
}
}
先启动服务端,再启动客户端,在客户端的控制台输入消息并回车,就可以发送消息给客户端了,客户端收到消息后,马上会回复一个消息
来源:https://blog.csdn.net/yubo_725/article/details/45331487
标签:java,TCP,聊天程序
0
投稿
猜你喜欢
应用Java泛型和反射导出CSV文件的方法
2022-02-25 19:50:17
Java中String类常用方法使用详解
2023-05-23 07:21:37
Spring Security OAuth过期的解决方法
2023-05-26 22:30:01
android同时控制EditText输入字符个数和禁止特殊字符输入的方法
2021-08-01 14:16:46
Java 如何实现时间控制
2023-02-20 06:19:23
SpringBoot项目中的多数据源支持的方法
2022-01-12 03:42:19
SpringBoot Security安装配置及Thymeleaf整合
2023-11-27 16:18:41
Java线程池的优点及池化技术的应用
2022-07-01 08:12:23
SpringCloud使用Feign实现远程调用流程详细介绍
2021-06-02 06:47:16
JAVA关键字及作用详解
2022-05-03 03:50:14
Java深入讲解异常处理try catch的使用
2023-11-04 13:00:32
Java对象类型的判断详解
2023-07-26 09:55:07
详细解读Java的Lambda表达式
2021-12-30 15:32:36
SpringBoot整合支付宝APP支付
2021-10-12 02:57:24
JAVA8 Stream流中的reduce()方法详解
2023-09-01 21:10:33
java 算法之归并排序详解及实现代码
2021-12-27 01:52:11
C#用Topshelf创建Windows服务的步骤分享
2022-10-19 00:47:58
springBoot整合rabbitMQ的方法详解
2022-08-19 02:28:33
java操作mongodb之多表联查的实现($lookup)
2023-08-08 10:24:07
SpringBoot自定义MessageConverter与内容协商管理器contentNegotiationManager详解
2023-11-28 11:35:54