服务器之家

服务器之家 > 正文

java实现简单TCP聊天程序

时间:2021-05-19 13:58     来源/作者:yubo_725

本文实例为大家分享了java实现tcp聊天程序的具体代码,供大家参考,具体内容如下

服务端代码:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
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();
  }
 }
 }
 
}

客户端代码:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
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

标签:

相关文章

热门资讯

2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全 2019-12-26
yue是什么意思 网络流行语yue了是什么梗
yue是什么意思 网络流行语yue了是什么梗 2020-10-11
背刺什么意思 网络词语背刺是什么梗
背刺什么意思 网络词语背刺是什么梗 2020-05-22
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总 2020-11-13
2021德云社封箱演出完整版 2021年德云社封箱演出在线看
2021德云社封箱演出完整版 2021年德云社封箱演出在线看 2021-03-15
返回顶部