基于java socket實(shí)現(xiàn) 聊天小程序
更新時(shí)間:2019年12月31日 13:15:59 作者:v慕言
這篇文章主要介紹了基于java socket實(shí)現(xiàn) 聊天小程序,代碼分為服務(wù)器和客戶端,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
服務(wù)器
package demo04; import java.awt.BorderLayout; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.WindowAdapter; import java.awt.event.WindowEvent; import java.io.DataInputStream; import java.io.DataOutputStream; import java.net.ServerSocket; import java.net.Socket; import javax.swing.JButton; import javax.swing.JFrame; import javax.swing.JOptionPane; import javax.swing.JPanel; import javax.swing.JScrollPane; import javax.swing.JTextArea; import javax.swing.JTextField; import javax.swing.ScrollPaneConstants; public class ownServer { public static void main(String[] args) { // TODO Auto-generated method stub new Server().launch(); } } class Server{ JFrame frame; JTextArea taArea; JTextField tfField; JButton sbButton; DataInputStream read ; DataOutputStream write; ServerSocket scServerSocket; Socket socket; public void launch() { CreateUI(); CreateNetWork(); new ServerWrite().start(); new ServerRead().start(); } public void CreateUI() { frame = new JFrame("MM Server"); JPanel Panle = new JPanel(); taArea = new JTextArea(15,25); taArea.setLineWrap(true); taArea.setWrapStyleWord(true); taArea.setEditable(true); JScrollPane qScroller=newJScrollPane(taArea); qScroller.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS); qScroller.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_ALWAYS); tfField = new JTextField(20); sbButton = new JButton("發(fā)送"); Panle.add(qScroller); Panle.add(tfField); Panle.add(sbButton); frame.getContentPane().add(BorderLayout.CENTER,Panle); frame.setSize(400,400); frame.setVisible(true); } public void close() { try { write.close(); read.close(); socket.close(); scServerSocket.close(); } catch (Exception e) { System.exit(-1); } } public void CreateNetWork() { try { scServerSocket =new ServerSocket(7780); socket= scServerSocket.accept(); read = new DataInputStream(socket.getInputStream()); write = new DataOutputStream(socket.getOutputStream()); System.out.print("網(wǎng)絡(luò)連接"); } catch (Exception e) { // TODO: handle exception e.printStackTrace(); } } class ServerRead extends Thread{ public void run() { while (true) { try { String message = read.readUTF(); taArea.append("對(duì)方:"+message+ "\n"); } catch (Exception e1) { // TODO: handle exception JOptionPane.showMessageDialog(taArea, "提示: 服務(wù)端已經(jīng)斷開連接"); //e.printStackTrace(); //System.exit(-1); return ; } } } } class ServerWrite extends Thread{ public void run() { tfField.addActionListener(new ServerListen()); sbButton.addActionListener(new ServerListen()); } } class ServerListen implements ActionListener{ @Override public void actionPerformed(ActionEvent e) { try { String str = tfField.getText(); tfField.setText(""); taArea.append("我: " + str + "\n"); write.writeUTF(str); } catch (Exception e2) { // TODO: handle exception e2.printStackTrace(); } } } }
客戶端
package demo04; import java.awt.BorderLayout; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.WindowAdapter; import java.awt.event.WindowEvent; import java.io.DataInputStream; import java.io.DataOutputStream; import java.net.Socket; import javax.swing.JButton; import javax.swing.JFrame; import javax.swing.JOptionPane; import javax.swing.JPanel; import javax.swing.JScrollPane; import javax.swing.JTextArea; import javax.swing.JTextField; import javax.swing.ScrollPaneConstants; public class ownClient { public static void main(String[] args) { // TODO Auto-generated method stub new Client().launch(); } } class Client{ JTextArea taArea; JTextField tfField; JButton sbButton; DataInputStream read = null; DataOutputStream write = null; Socket socket; public void launch() { CreateUI(); CreatNetWork(); new ClientRead().start();; new ClientWrite().start();; } public void CreateUI() { JFrame frame = new JFrame("MM Client"); JPanel Panle = new JPanel(); taArea = new JTextArea(15,25); taArea.setLineWrap(true); taArea.setWrapStyleWord(true); taArea.setEditable(true); JScrollPane qScroller = new JScrollPane(taArea); qScroller.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS); qScroller.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_ALWAYS); tfField = new JTextField(20); sbButton = new JButton("發(fā)送"); Panle.add(qScroller); Panle.add(tfField); Panle.add(sbButton); frame.getContentPane().add(BorderLayout.CENTER,Panle); frame.setSize(400,400); frame.setVisible(true); } public void CreatNetWork() { // TODO Auto-generated method stub try { socket = new Socket("127.0.0.1",7780); write = new DataOutputStream(socket.getOutputStream()); read = new DataInputStream(socket.getInputStream()); System.out.print("已建立網(wǎng)絡(luò)連接"); } catch (Exception e) { // TODO: handle exception e.printStackTrace(); } } class ClientRead extends Thread{ public void run() { while (true) { try { String message= read.readUTF(); taArea.append("對(duì)方:"+message+ "\n"); } catch (Exception e1) { // TODO: handle exception JOptionPane.showMessageDialog(taArea, "提示: 客戶端已經(jīng)斷開連接"); //e.printStackTrace(); //System.exit(-1); return ; } } } } class ClientWrite extends Thread{ public void run() { tfField.addActionListener(new ClientListen()); sbButton.addActionListener(new ClientListen()); } } class ClientListen implements ActionListener{ @Override public void actionPerformed(ActionEvent e) { try { String str = tfField.getText(); tfField.setText(""); taArea.append("我: " + str + "\n"); write.writeUTF(str); } catch (Exception e2) { // TODO: handle exception e2.printStackTrace(); } } } }
總結(jié)
以上所述是小編給大家介紹的基于java socket實(shí)現(xiàn) 聊天小程序,希望對(duì)大家有所幫助!
您可能感興趣的文章:
- Java單線程程序?qū)崿F(xiàn)實(shí)現(xiàn)簡單聊天功能
- JAVA Netty實(shí)現(xiàn)聊天室+私聊功能的示例代碼
- java基于netty NIO的簡單聊天室的實(shí)現(xiàn)
- 基于Java的Socket多客戶端Client-Server聊天程序的實(shí)現(xiàn)
- 基于Java的Socket編寫的C/S聊天程序?qū)崿F(xiàn)
- Java使用TCP實(shí)現(xiàn)在線聊天的示例代碼
- Java NIO實(shí)戰(zhàn)之聊天室功能詳解
- Java SE實(shí)現(xiàn)多人聊天室功能
- java基于C/S結(jié)構(gòu)實(shí)現(xiàn)多線程聊天室
- java基于C/S模式實(shí)現(xiàn)聊天程序(服務(wù)器)
- java基于C/S模式實(shí)現(xiàn)聊天程序(客戶端)
- java使用MulticastSocket實(shí)現(xiàn)基于廣播的多人聊天室
- Java 網(wǎng)絡(luò)編程之 TCP 實(shí)現(xiàn)簡單的聊天系統(tǒng)
相關(guān)文章
SpringBoot配置MyBatis-Plus實(shí)現(xiàn)增刪查改
本文主要介紹了SpringBoot配置MyBatis-Plus實(shí)現(xiàn)增刪查改,文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2021-08-08

Java+Spring+MySql環(huán)境中安裝和配置MyBatis的教程
這篇文章主要介紹了Java+Spring+MySql環(huán)境中安裝和配置MyBatis的教程,MyBatis一般被用來增強(qiáng)數(shù)據(jù)庫操作,文中對(duì)MyBatis的主配置文件有較為詳細(xì)的講解,需要的朋友可以參考下
2016-04-04