溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要介紹“怎么使用Java socket通信模擬QQ實現多人聊天室”，在日常操作中，相信很多人在怎么使用Java socket通信模擬QQ實現多人聊天室問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”怎么使用Java socket通信模擬QQ實現多人聊天室”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！
socket 通信是基于TCP/IP ?絡層上的?種傳送?式，我們通常把TCP和UDP稱為傳輸層。
如上圖，在七個層級關系中，我們講的socket屬于傳輸層，其中UDP是?種?向?連接的傳輸層協(xié)議。UDP不關?對端是否真正收到了傳送過去的數據。如果需要檢查對端是否收到分組數據包，或者對端是否連接到?絡，則需要在應?程序中實現。UDP常?在分組數據較少或多播、?播通信以及視頻通信等多媒體領域。在這?我們不進?詳細討論，這?主要講解的是基于TCP/IP協(xié)議下的socket通信。
socket是基于應?服務與TCP/IP通信之間的?個抽象，他將TCP/IP協(xié)議??復雜的通信邏輯進?分裝，對?戶來說，只要通過?組簡單的API就可以實現?絡的連接。
對socket通信基本原理明?后，那我們就寫?個最簡單的?例，制作聊天室。
服務器端Server：
import java.io.*;
import java.net.*;
import java.util.ArrayList;
public class Server{
public static ServerSocket server_socket;
public static ArrayList<Socket> socketList=new ArrayList<Socket>();
public static void main(String []args){
try{
server_socket = new ServerSocket(5000);
while(true){
Socket socket = server_socket.accept();
socketList.add(socket); //把sock對象加入sock集合
ServerBO_Thread st=new ServerBO_Thread(socket,socketList); //初始化多線程
st.start();//啟動多線程
}
}catch(Exception ex){
ex.printStackTrace();
}finally{
try{
if(server_socket!=null){
server_socket.close();
}
}catch(Exception ex){
ex.printStackTrace();
}
}
}
public void encryptWrite(String src,DataOutputStream output)throws IOException{
//將一個字符串轉化為字符數組
//System.out.println(src);
char[] char_arr = src.toCharArray();
//加密操作
for(int i = 0;i<char_arr.length;i++){
output.writeChar(char_arr[i]+13);
}
//用作結束標志符
output.writeChar(2333);
output.flush();
}
//讀取并解密
public String readDecrypt(DataInputStream input)throws IOException{
String rtn="";
while(true){
int char_src =input.readChar();
if(char_src!=2333){
rtn=rtn+(char)(char_src-13);
}else{
break;
}
}
return rtn;
}
}
class ServerBO_Thread extends Thread{
Socket client = null;
ArrayList<Socket> clients;
ServerBO_Thread(Socket s,ArrayList<Socket> ss){//初始化
client=s;
clients=ss;
}
public void run(){
DataInputStream input = null;
DataOutputStream output =null;
try{
input = new DataInputStream(client.getInputStream());
Server bo = new Server();
String receive=null;
String send=null;
while(true){//監(jiān)視當前客戶端有沒有發(fā)來消息
if(!client.isClosed()){
receive=bo.readDecrypt(input);
clients.trimToSize();
String[] param = receive.split("&");
if(")start".equals(param[1])){ //分析客戶端發(fā)來的內容
send = param[0]+"進入聊天室";
}else{
send = param[0]+"說: "+param[1];
}
if(!("3333".equals(param[1]))){//3333為退出聊天室信號
for(Socket socket:clients){ //遍歷socke集合
//把讀取到的消息發(fā)送給各個客戶端
if(!socket.isClosed()){
output = new DataOutputStream(socket.getOutputStream());
bo.encryptWrite(send,output);
}
}
}else{//如果有客戶端退出
for(Socket socket:clients){ //遍歷socke集合
if(socket!=client){//告訴其他人此人退出聊天室
if(!(socket.isClosed())){
output = new DataOutputStream(socket.getOutputStream());
bo.encryptWrite(param[0]+"已退出聊天室",output);
}
}
}
output = new DataOutputStream(client.getOutputStream());
bo.encryptWrite("3333",output);//返回信號給要退出的客戶端，然后關閉線程
client.close();
input.close();
output.close();
}
}else{
break;
}
}
}catch(Exception ex){
ex.printStackTrace();
}
}
}客戶端：
import java.io.IOException;
import java.util.Scanner;
import java.net.*;
import java.io.*;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.BufferedWriter;
import java.io.BufferedReader;
import java.io.DataOutputStream;
public class People{
//服務端ip
public String ip = "127.0.0.1";
//服務端端口
public int port = 5000;
public DataOutputStream output = null;
public Socket socket = null;
public DataInputStream input = null;
public Scanner sc =new Scanner (System.in);
public String send ;
public String receive;
public String name;
public String sd = null;
public static void main(String[]aa){
People po = new People();
po.start();
}
public void start(){
try{
System.out.println("*******歡迎使用匿名聊天室！**********");
System.out.println("請輸入你將要使用的昵稱：");
name=sc.nextLine();//獲取昵稱
socket = new Socket(ip,port);
output=new DataOutputStream(socket.getOutputStream());
input = new DataInputStream(socket.getInputStream());
send = name+"&)start";//把昵稱發(fā)送到server 告訴所有人有新成員加入聊天室
System.out.println("(如果要退出聊天室請輸入“3333”！)");
System.out.println("*******成功進入匿名聊天室！**********");
System.out.println("");
encryptWrite(send,output);
Out out=new Out(output,name,input,socket);
out.start();//啟動發(fā)送聊天內容的多線程
while(true){
String receive = readDecrypt(input);
if("3333".equals(receive)){//如果收到“3333”則退出聊天室
System.out.println("*******成功退出匿名聊天室！**********");
input.close();
output.close();
socket.close();
System.exit(0);
}
System.out.println(receive);
}
}catch(Exception ex){
ex.printStackTrace();
}finally{
try{
if(socket!=null) socket.close();
input.close();
output.close();
}catch(Exception ex){
ex.printStackTrace();
}
}
}
public void encryptWrite(String src,DataOutputStream output)throws IOException{
//將一個字符串轉化為字符數組
char[] char_arr = src.toCharArray();
//加密操作
for(int i = 0;i<char_arr.length;i++){
output.writeChar(char_arr[i]+13);
}
//用作結束標志符
output.writeChar(2333);
output.flush();
}
//讀取并解密
public String readDecrypt(DataInputStream input)throws IOException{
String rtn="";
while(true){
int char_src =input.readChar();
if(char_src!=2333){
rtn=rtn+(char)(char_src-13);
}else{
break;
}
}
return rtn;
}
}
class Out extends Thread {
public DataOutputStream output;
public DataInputStream input;
public static String name;
public Socket socket;
public Scanner sc =new Scanner (System.in);
Out(DataOutputStream ot,String n,DataInputStream it,Socket socket){
output=ot;
input=it;
name=n;
}
public void run(){
People po = new People();
try{
while(true){
String send=sc.nextLine();//獲取用戶輸入
String send2=name+"&"+send;//把聊天內容打包成約定形式
po.encryptWrite(send2,output);
}
}catch(Exception ex){
ex.printStackTrace();
}finally{
System.out.println("sfef");
}
}
}
到此，關于“怎么使用Java socket通信模擬QQ實現多人聊天室”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續(xù)學習更多相關知識，請繼續(xù)關注億速云網站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>
免責聲明：本站發(fā)布的內容（圖片、視頻和文字）以原創(chuàng)、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
