tipservermanagerbean.java

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

package com.vere.udp.server;

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

import javax.swing.JFrame;
import javax.swing.JPanel;

import javax.swing.*;
import javax.swing.JButton;
import javax.swing.JTextArea;
import javax.swing.JList;

import com.vere.oa.waitaffair.item.Oa_waitaffairItem;
import com.vere.oa.waitaffair.xml.Oa_waitaffairXmlBean;
import javax.swing.JTextField;
import javax.swing.JLabel;
public class TipServerManagerBean  extends Thread {

	private DatagramSocket ds ;//开始监视端口
	private DatagramSocket dsClient ;//开始监视端口
	private DatagramPacket ip;//创建接收数据报的实例
	private Oa_waitaffairXmlBean oa_waitaffairXmlBean=new Oa_waitaffairXmlBean();
	
	
	
	
	public TipServerManagerBean()
	{
		super();
		initialize();
	}

	private void initialize() {
		runClient();
	}
	
	public void runClient(){//接收客户端的消息
		
		//数据报服务
		try { 
			byte[] buf = new byte[1000];
	 		dsClient = new DatagramSocket(12345);
			//开始监视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("&");
				 //删除已经接受到消息的客户
				 Oa_waitaffairItem oa_waitaffairItem=new Oa_waitaffairItem();
				oa_waitaffairItem.setId(revArray[0]);
				oa_waitaffairItem.setWaitaffair_type(revArray[1]);
				oa_waitaffairItem.setTitle(revArray[2]);
				oa_waitaffairItem.setSend_user(revArray[3]);
				oa_waitaffairItem.setSend_name(revArray[4]);
				oa_waitaffairItem.setReceive_user(revArray[5]);
				oa_waitaffairItem.setReceive_name(revArray[6]);
				oa_waitaffairItem.setReceive_ip(revArray[7]);
				oa_waitaffairItem.setSend_time(revArray[8]);
				oa_waitaffairXmlBean.removeXML(oa_waitaffairItem);
			}
		} 
		catch(Throwable t) { 
			t.printStackTrace(); 
		}finally{
			dsClient.close();
		}
	}

}