chatudpserver.java

来自「java实用系统开发指南里面包含好多很好的系统讲解」· Java 代码 · 共 45 行

package com.jdon.jserver.application.chat;

import java.io.*;
import com.jdon.jserver.application.connection.ConnectionFactory;
import com.jdon.jserver.application.Connection;

public class ChatUDPServer implements Runnable {
  private ConnectionFactory connFactory = ConnectionFactory.getInstance(
      ConnectionFactory.UDPSERVER);

  public void run() {
    try {
      while (true) {
        udpConnect();
        Thread.sleep(300L);
      }
    } catch (Exception ex) {
    }

  }

  private void udpConnect() throws Exception {
    Connection conn = connFactory.getUdpConnection();

    String clientMsg = conn.readString();
    System.out.println("clientMsg==" + clientMsg);

    ///////////////////////////////////////////
    StringBuffer buff = new StringBuffer(clientMsg);
    buff.append("come back again!");

    String newclientMsg = buff.toString();
    conn.writeString(newclientMsg);

    System.out.println("send :" + newclientMsg);

  }

  public static void main(String[] args) {
    Thread chat = new Thread(new ChatUDPServer());
    chat.start();

  }

}