java實(shí)現(xiàn)簡單TCP聊天程序
本文實(shí)例為大家分享了java實(shí)現(xiàn)TCP聊天程序的具體代碼，供大家參考，具體內(nèi)容如下
固安ssl適用于網(wǎng)站、小程序/APP、API接口等需要進(jìn)行數(shù)據(jù)傳輸應(yīng)用場景，ssl證書未來市場廣闊！成為創(chuàng)新互聯(lián)的ssl證書銷售渠道，可以享受市場價(jià)格4-6折優(yōu)惠！如果有意向歡迎電話聯(lián)系或者加微信：13518219792（備注：SSL證書合作）期待與您的合作！
服務(wù)端代碼：
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 {
//服務(wù)器在9990端口監(jiān)聽客戶端的連接
ServerSocket ss = new ServerSocket(9999);
System.out.println("server is listening...");
while(true){
//阻塞的accept方法，當(dāng)一個(gè)客戶端連接上，才會(huì)返回Socket對(duì)象
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();
//讀取客戶端發(fā)過來的消息
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 {
//連接到服務(wù)器
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);//發(fā)給服務(wù)端
System.out.println("client send msg : " + line);
}
} catch (Exception e) {
e.printStackTrace();
}
}
//監(jiān)聽服務(wù)端回復(fù)的消息
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();
}
}先啟動(dòng)服務(wù)端，再啟動(dòng)客戶端，在客戶端的控制臺(tái)輸入消息并回車，就可以發(fā)送消息給客戶端了，客戶端收到消息后，馬上會(huì)回復(fù)一個(gè)消息
以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持創(chuàng)新互聯(lián)。
網(wǎng)站名稱：java實(shí)現(xiàn)簡單TCP聊天程序
本文網(wǎng)址：http://www.jiaotiyi.com/article/pcdppe.html