tipclientbean.java

来自「java开发的办公系统 1.系统管理 (地区管理,部门管理,菜单管理,用户管理」· Java 代码 · 共 80 行

package com.vere.udp.server;

import java.net.*; 
import java.util.List;
import java.io.*;

import com.vere.oa.waitaffair.item.Oa_waitaffairItem;
import com.vere.oa.waitaffair.xml.Oa_waitaffairXmlBean;

public class TipClientBean  extends Thread  {

	private DatagramSocket ds ;//开始监视端口
	private DatagramSocket dsClient ;//开始监视端口
	private DatagramPacket ip;//创建接收数据报的实例
	
	private static TipClientBean tipClientBean;
	
	public static void main(String[] args) {
		tipClientBean=new TipClientBean();
		tipClientBean.start();
	}
	
	public void run(){
		//数据报服务
		try { 
			byte[] buf = new byte[1000];
	 		dsClient = new DatagramSocket(9999);
			//开始监视12345端口
	 		ip = new DatagramPacket(buf, buf.length);
	 		 String rev="";
			while (true)
			{
				dsClient.receive(ip);
				//阻塞，直到收到数据报后将数据装入IP中
				 rev=new String(buf,0,ip.getLength());
				 String[] revArray=rev.split("&");				 
			 	TipsDialog tipsDialog=new TipsDialog();
			 	tipsDialog.jLelMessage.setText("您好："+revArray[6]+" 您有新的"+revArray[2]);
			 	tipsDialog.setModal(true);
			 	tipsDialog.show();
			 	tipsDialog.setVisible(true);
			 	//runClient(rev);
			}
		} 
		catch(Throwable t) { 
			t.printStackTrace(); 
		}finally{
			dsClient.close();
		}
    }
	
	public void runClient(String rev){
		try { 
			
			//得到目标机器的地址实例
			ds = new DatagramSocket(9999);
			InetAddress target = dsClient.getLocalAddress();
			//要发送的数据
			String sendData=rev;
			byte[] buf = sendData.getBytes();
			//将数据转换成Byte类型
			DatagramPacket op = new DatagramPacket(buf, buf.length, target, 12345);
			//将BUF缓冲区中的数据打包
			ds.send(op);
			//发送数据
			op=null;
		} 
		catch(Exception t) { 
			System.out.println(t.toString());
		}finally
		{
			ds.close();
			ds=null;
			//关闭连接
		}
    }
	
}