欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

java中UDP簡單聊天程序實例代碼

 更新時間：2013年12月31日 16:08:38   作者：  
這篇文章主要介紹了java中UDP簡單聊天程序實例代碼，有需要的朋友可以參考一下

學過計算機網絡通信的都知道，計算機之間傳送數據由兩種，即TCP通信和UDP通信。TCP是可靠的面向連接的通信協議，二UDP是不可靠的面向無連接的通信協議。

java中有基于TCP的網絡套接字通信，也有基于UDP的用戶數據報通信，UDP的信息傳輸速度快，但不可靠！

基于UDP通信的基本模式：

（1）將數據打包，稱為數據包（好比將信件裝入信封一樣），然后將數據包發(fā)往目的地。

（2）接受別人發(fā)來的數據包（好比接收信封一樣），然后查看數據包中的內容。

客戶機

復制代碼 代碼如下:

package com.client.view;

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.ObjectOutputStream;

import javax.swing.ImageIcon;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JTextArea;
import javax.swing.JTextField;

import com.tools.ClientToServerThread;

/**
 * @author lenovo
 *
 */
public class JChatFrm extends JFrame implements ActionListener{


 JTextArea jta;
 JTextField jtf;
 JButton jb;
 JPanel jp;
 String ownerId;
 String friendId;

 ClientToServerThread ctsT;
 public static void main(String[] args) {
  // TODO Auto-generated method stub
  new JChatFrm();
 }

 public JChatFrm()
 {
  setTitle("客戶端");
  jta=new JTextArea();
  jtf=new JTextField(15);
  jb=new JButton("發(fā)送");
  jb.addActionListener(this);
  jp=new JPanel();
  jp.add(jtf);
  jp.add(jb);

  this.add(jta,"Center");
  this.add(jp,"South");
 // this.setTitle(ownerId+" 正在和 "+friend+" 聊天");
  this.setIconImage((new ImageIcon("image/qq.gif").getImage()));
 // this.setSize(300, 200);
  this.setBounds(300, 200, 300, 200);
  this.setVisible(true);
  setDefaultCloseOperation(JFrame.DISPOSE_ON_CLOSE);
  ctsT = new ClientToServerThread(jta);
  ctsT.start();

  /**窗體關閉按鈕事件*/
  this.addWindowListener(new WindowAdapter()
  {
   public void windowClosing(WindowEvent e)
   {
    if(JOptionPane.showConfirmDialog(null, "<html><font size=3>確定退出嗎？</html>","系統提示",JOptionPane.OK_CANCEL_OPTION,JOptionPane.INFORMATION_MESSAGE)==0)
    {  
     System.exit(0);
     ctsT.closeSocket();
    }
    else
    {
     return;
    }
   }
  }
  );
 }

 //寫一個方法，讓它顯示消息
 public void showMessage(String message)
 {
  String info= message;
  this.jta.append(info);
 }

 public void actionPerformed(ActionEvent arg0) {
  // TODO Auto-generated method stub
  if(arg0.getSource()==jb)
  {   
   byte buffer[] = jtf.getText().trim().getBytes();
   ctsT.sendData(buffer);
  }

 }
}

復制代碼 代碼如下:

package com.tools;

import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Properties;

import javax.swing.JTextArea;

import com.common.User;

/**
 * @author lenovo
 *
 */
public class ClientToServerThread extends Thread{

 private String serverIP = "127.0.0.1";
 private int serverPORT = 8888;
 private int receivePORT = 6666;
 //聲明發(fā)送信息的數據報套結字
    private DatagramSocket sendSocket = null;
    //聲明發(fā)送信息的數據包
    private DatagramPacket sendPacket = null;
    //聲明接受信息的數據報套結字
    private DatagramSocket receiveSocket = null;
    //聲明接受信息的數據報
    private DatagramPacket receivePacket = null;
    //收發(fā)數據的端口
    private int myPort = 0;
    //接收數據主機的IP地址
    private String friendIP = null;
    private int friendPort = 0;

    //緩沖數組的大小
    public static final int BUFFER_SIZE = 5120;

    private byte inBuf[] = null; //接收數據的緩沖數組
    private byte outBuf[] = null; //發(fā)送數據的緩沖數組

    JTextArea jta;

 // 構造函數
 public ClientToServerThread(JTextArea jta) {
  this.jta = jta;
  getPropertiesInfo();
 }

 public void run() {
  String receiveInfo = "";
  try{
   inBuf = new byte[BUFFER_SIZE];
   receivePacket = new DatagramPacket(inBuf,inBuf.length);
   receiveSocket = new DatagramSocket(receivePORT);
  }catch (Exception e) {
   e.printStackTrace();
   // TODO: handle exception
  }

  while (true) {
   if(receiveSocket == null){
    break;
   } else {
    try {
     receiveSocket.receive(receivePacket);
     String message = new String(receivePacket.getData(),0,receivePacket.getLength());
     jta.append("收到數據"+message+"\n");
    } catch (Exception e) {
     e.printStackTrace();
     // TODO: handle exception
    }
   }
  }
 }
 /**
  * 該方法用來獲得服務器屬性文件中的IP、PORT
  */
 private void getPropertiesInfo(){
  Properties prop = new Properties();
  InputStream inStream = Thread.currentThread().getContextClassLoader()
    .getResourceAsStream("ServerInfo.properties");
  try{
   //獲得相應的鍵值對
   prop.load(inStream);
  }catch(IOException e){
   e.printStackTrace();
  }

  //根據相應的鍵獲得對應的值
  serverIP = prop.getProperty("serverip");
  serverPORT = Integer.parseInt(prop.getProperty("serverudp.port"));
  receivePORT = Integer.parseInt(prop.getProperty("receiveudp.port"));

       
 }
 public void sendData(byte buffer[]){
  try{
   InetAddress address = InetAddress.getByName(serverIP);
  // outBuf = new byte[BUFFER_SIZE];
   sendPacket = new DatagramPacket(buffer,buffer.length,address,serverPORT);
   sendSocket = new DatagramSocket();
   sendSocket.send(sendPacket);
  }catch (Exception e) {
   e.printStackTrace();
   // TODO: handle exception
  }
 }
    public void closeSocket(){
     receiveSocket.close();
    }
}

服務器：

復制代碼 代碼如下:

package com.server.view;

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.ObjectOutputStream;

import javax.swing.ImageIcon;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JTextArea;
import javax.swing.JTextField;

import com.tools.ClientToServerThread;

/**
 * @author lenovo
 *
 */
public class JChatFrm extends JFrame implements ActionListener{


 JTextArea jta;
 JTextField jtf;
 JButton jb;
 JPanel jp;
 String ownerId;
 String friendId;

 ClientToServerThread ctsT;
 public static void main(String[] args) {
  // TODO Auto-generated method stub
  new JChatFrm();
 }

 public JChatFrm()
 {
  setTitle("服務器");
  jta=new JTextArea();
  jtf=new JTextField(15);
  jb=new JButton("發(fā)送");
  jb.addActionListener(this);
  jp=new JPanel();
  jp.add(jtf);
  jp.add(jb);

  this.add(jta,"Center");
  this.add(jp,"South");
 // this.setTitle(ownerId+" 正在和 "+friend+" 聊天");
  this.setIconImage((new ImageIcon("image/qq.gif").getImage()));
 // this.setSize(300, 200);
  this.setBounds(300, 200, 300, 200);
  this.setVisible(true);
  setDefaultCloseOperation(JFrame.DISPOSE_ON_CLOSE);
  ctsT = new ClientToServerThread(jta);
  ctsT.start();

  /**窗體關閉按鈕事件*/
  this.addWindowListener(new WindowAdapter()
  {
   public void windowClosing(WindowEvent e)
   {
    if(JOptionPane.showConfirmDialog(null, "<html><font size=3>確定退出嗎？</html>","系統提示",JOptionPane.OK_CANCEL_OPTION,JOptionPane.INFORMATION_MESSAGE)==0)
    {  
     System.exit(0);
     ctsT.closeSocket();
    }
    else
    {
     return;
    }
   }
  }
  );
 }

 //寫一個方法，讓它顯示消息
 public void showMessage(String message)
 {
  String info= message;
  this.jta.append(info);
 }

 public void actionPerformed(ActionEvent arg0) {
  // TODO Auto-generated method stub
  if(arg0.getSource()==jb)
  {      
   byte buffer[] = jtf.getText().trim().getBytes();
   ctsT.sendData(buffer);
  }

 }
}

復制代碼 代碼如下:

package com.tools;

import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Properties;

import javax.swing.JTextArea;

import com.common.User;

/**
 * @author lenovo
 *
 */
public class ClientToServerThread extends Thread{

 private String sendIP = "127.0.0.1"; 
 private int sendPORT = 6666;
 private int receivePORT = 8888;
 //聲明發(fā)送信息的數據報套結字
    private DatagramSocket sendSocket = null;
    //聲明發(fā)送信息的數據包
    private DatagramPacket sendPacket = null;
    //聲明接受信息的數據報套結字
    private DatagramSocket receiveSocket = null;
    //聲明接受信息的數據報
    private DatagramPacket receivePacket = null;
    //收發(fā)數據的端口
    private int myPort = 0;
    //接收數據主機的IP地址
    private String friendIP = null;
    private int friendPort = 0;

    //緩沖數組的大小
    public static final int BUFFER_SIZE = 5120;

    private byte inBuf[] = null; //接收數據的緩沖數組
    private byte outBuf[] = null; //發(fā)送數據的緩沖數組

    JTextArea jta;

 // 構造函數
 public ClientToServerThread(JTextArea jta) {
  this.jta = jta;
  getPropertiesInfo();
 }

 public void run() {
  String receiveInfo = "";
  try{
   inBuf = new byte[BUFFER_SIZE];
   receivePacket = new DatagramPacket(inBuf,inBuf.length);
   receiveSocket = new DatagramSocket(receivePORT);
  }catch (Exception e) {
   e.printStackTrace();
   // TODO: handle exception
  }

  while (true) {
   if(receiveSocket == null){
    break;
   } else {
    try {
     receiveSocket.receive(receivePacket);
     String message = new String(receivePacket.getData(),0,receivePacket.getLength());
     jta.append("收到數據"+message+"\n");
    } catch (Exception e) {
     e.printStackTrace();
     // TODO: handle exception
    }
   }
  }
 }
 /**
  * 該方法用來獲得服務器屬性文件中的IP、PORT
  */
 private void getPropertiesInfo(){
  Properties prop = new Properties();
  InputStream inStream = Thread.currentThread().getContextClassLoader()
    .getResourceAsStream("ServerInfo.properties");
  try{
   //獲得相應的鍵值對
   prop.load(inStream);
  }catch(IOException e){
   e.printStackTrace();
  }

  //根據相應的鍵獲得對應的值

  receivePORT = Integer.parseInt(prop.getProperty("serverudp.port"));

  

 }
 public void sendData(byte buffer[]){
  try{
   InetAddress address = InetAddress.getByName(sendIP);
  // outBuf = new byte[BUFFER_SIZE];
   sendPacket = new DatagramPacket(buffer,buffer.length,address,sendPORT);
   sendSocket = new DatagramSocket();
   sendSocket.send(sendPacket);
  }catch (Exception e) {
   e.printStackTrace();
   // TODO: handle exception
  }
 }
 public void closeSocket(){
     receiveSocket.close();
    }
}

運行截圖：

相關文章

  • 詳解spring security安全防護

    詳解spring security安全防護

    這篇文章主要介紹了詳解spring security安全防護，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
    2018-07-07
  • 詳解spring boot實現多數據源代碼實戰(zhàn)

    詳解spring boot實現多數據源代碼實戰(zhàn)

    本篇文章主要介紹了詳解spring boot實現多數據源代碼實戰(zhàn)，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
    2017-07-07
  • Java FTPClient實現文件上傳下載

    Java FTPClient實現文件上傳下載

    這篇文章主要為大家詳細介紹了Java FTPClient實現文件上傳下載的相關資料,需要的朋友可以參考下
    2016-04-04
  • 通過openOffice將office文件轉成pdf

    通過openOffice將office文件轉成pdf

    這篇文章主要介紹了通過openOffice將office文件轉成pdf,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2020-11-11
  • IDEA插件EasyCode及MyBatis最優(yōu)配置步驟詳解

    IDEA插件EasyCode及MyBatis最優(yōu)配置步驟詳解

    這篇文章主要介紹了IDEA插件EasyCode MyBatis最優(yōu)配置步驟詳解,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
    2020-12-12
  • PowerJob的DispatchStrategy方法工作流程源碼解讀

    PowerJob的DispatchStrategy方法工作流程源碼解讀

    這篇文章主要為大家介紹了PowerJob的DispatchStrategy方法工作流程源碼解讀,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2024-01-01
  • java版數獨游戲核心算法（一）

    java版數獨游戲核心算法（一）

    這篇文章主要為大家詳細介紹了java版數獨游戲的核心算法，具有一定的參考價值，感興趣的小伙伴們可以參考一下
    2017-12-12
  • 淺析Java多線程同步synchronized

    淺析Java多線程同步synchronized

    本篇文章給大家詳細分析了Java多線程同步synchronized的相關知識點，需要的讀者們可以參考學習下。
    2018-02-02
  • SpringCloud Feign服務調用請求方式總結

    SpringCloud Feign服務調用請求方式總結

    這篇文章主要介紹了SpringCloud Feign服務調用方式總結,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2020-04-04
  • MyBatis中的連接池及事物控制配置過程

    MyBatis中的連接池及事物控制配置過程

    連接池就是用于存儲數據庫連接的一個容器,容器其實就是一個集合對象，本文給大家介紹MyBatis中的連接池以及事物控制的相關知識，感興趣的朋友一起看看吧
    2021-05-05

最新評論