Java基于socket实现简易聊天室实例

2019-12-19 13:32wo_soul JAVA教程

这篇文章主要介绍了Java基于socket实现简易聊天室的方法,实例分析了java基于socket实现聊天室服务端与客户端的相关技巧,需要的朋友可以参考下

本文实例讲述了Java基于socket实现简易聊天室的方法。分享给大家供大家参考。具体实现方法如下：

chatroomdemo.java

				?

									package com.socket.demo; 

									import java.io.IOException; 

									import java.net.DatagramSocket; 

									public class ChatRoomDemo { 

									  /** 

									   * @param args 

									   * @throws IOException 

									   */

									  public static void main(String[] args) throws IOException { 

									    System.out.println("----进入聊天室----"); 

									    DatagramSocket send = new DatagramSocket(); 

									    DatagramSocket rece = new DatagramSocket(10001); 

									    new Thread(new SendDemo(send)).start();// 启动发送端线程 

									    new Thread(new ReceiveDemo(rece)).start();// 启动接收端线程 

									  } 

									}

SendDemo.java

				?

									package com.socket.demo; 

									import java.io.BufferedReader; 

									import java.io.InputStreamReader; 

									import java.net.DatagramPacket; 

									import java.net.DatagramSocket; 

									import java.net.InetAddress; 

									public class SendDemo implements Runnable { 

									  private DatagramSocket ds; 

									  // 有参数构造函数 

									  public SendDemo(DatagramSocket ds) { 

									    this.ds = ds; 

									  } 

									  @Override

									  public void run() { 

									    try { 

									      BufferedReader bufr = new BufferedReader(new InputStreamReader( 

									          System.in)); 

									      String line = null; 

									      while ((line = bufr.readLine()) != null) { 

									        byte[] buf = line.getBytes(); 

									        /* 

									         * //192.168.1.255是ip段广播地址，发给这个IP的信息， 

									         * 在192.168.1.1-192.168.1.255的ip段的所有IP地址都能收到消息 

									         */

									        DatagramPacket dp = new DatagramPacket(buf, buf.length,InetAddress.getByName("192.168.1.255"), 10001);

									        ds.send(dp); 

									        if ("886".equals(line)) 

									          break; 

									      } 

									      ds.close(); 

									    } catch (Exception e) { 

									    } 

									  } 

									}

ReceiveDemo.java

				?

									package com.socket.demo; 

									import java.net.DatagramPacket; 

									import java.net.DatagramSocket; 

									public class ReceiveDemo implements Runnable { 

									  private DatagramSocket ds; 

									  public ReceiveDemo(DatagramSocket ds) { 

									    this.ds = ds; 

									  } 

									  @Override

									  public void run() { 

									    try { 

									      while (true) { 

									        // 2,创建数据包。 

									        byte[] buf = new byte[1024]; 

									        DatagramPacket dp = new DatagramPacket(buf, buf.length);

									        // 3,使用接收方法将数据存储到数据包中。 

									        ds.receive(dp);// 阻塞式的。 

									        // 4，通过数据包对象的方法，解析其中的数据,比如，地址，端口，数据内容。 

									        String ip = dp.getAddress().getHostAddress(); 

									        int port = dp.getPort(); 

									        System.out.println("----port-----" + port); 

									        String text = new String(dp.getData(), 0, dp.getLength()); 

									        System.out.println(ip + "::" + text); 

									        if (text.equals("886")) { 

									          System.out.println(ip + "....退出聊天室"); 

									        } 

									      } 

									    } catch (Exception e) { 

									    } 

									  } 

									}