[java]代碼庫package com.gufengxiachen.sthreadchatapp;

/**

* @author GUXIA

*/

import java.io.BufferedReader;

import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.net.ServerSocket;

import java.net.Socket;

public class ChatServer {

public static void main(String[] args) {

try {

//創建服務器端套接字，接受來自客戶端的連接請求

ServerSocket ss=new ServerSocket(9999);

Socket s=ss.accept();

//獲取客戶端套接字的輸出流

OutputStream os=s.getOutputStream();

DataOutputStream dos=new DataOutputStream(os);

//獲取客戶端輸入流

InputStream is=s.getInputStream();

DataInputStream dis=new DataInputStream(is);

//創建字符輸入流接受鍵盤輸入

InputStreamReader isr=new InputStreamReader(System.in);

BufferedReader br=new BufferedReader(isr);

String message;

while(true){

//獲取客戶端輸入流，并打印在屏幕上，如果客戶端說的是“再見”,退出

message=dis.readUTF();

System.out.println("客戶端："+message);

if(message.equals("再見"))

break;

//讀取鍵盤輸入并寫入到輸出流(客戶端的輸入流)

message=br.readLine();

dos.writeUTF(message);

}

dis.close();

dos.close();

ss.close();

s.close();

} catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

}

}

}

//源代碼片段來自云代碼http://yuncode.net

package com.gufengxiachen.sthreadchatapp;

/**

* @author GUXIA

*/

import java.io.BufferedReader;

import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.net.Socket;

public class ChatClient {

public static void main(String[] args) {

try {

//創建客戶端套接字

Socket sc=new Socket("localhost",9999);

//獲取套接字輸入流

InputStream is=sc.getInputStream();

DataInputStream dis=new DataInputStream(is);

//獲取套接字輸出流

OutputStream os=sc.getOutputStream();

DataOutputStream dos=new DataOutputStream(os);

//創建字符輸入流接受鍵盤輸入

InputStreamReader isr=new InputStreamReader(System.in);

BufferedReader br=new BufferedReader(isr);

//聊天

String message;

while(true){

//讀取鍵盤輸入的字符，寫到客戶端輸出流

message=br.readLine();

dos.writeUTF(message);

if(message.equals("再見"))

break;

//讀取服務器端的數據并打印到屏幕上

message=dis.readUTF();

System.out.println("服務器："+message);

}

dis.close();

dos.close();

sc.close();

} catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

}

}

}

//源代碼片段來自云代碼http://yuncode.net

總結

以上是生活随笔為你收集整理的java socket编程实现聊天程序_java Socket编程 聊天程序 服务器端和客户端的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。