chatroom.java

基于JSP的客户关系管理系统.rar 使用jsp和oracl

package com.test;

import java.net.*;
import java.io.*;
import java.awt.*;
import java.awt.event.*;
import java.applet.*;

public class chatroom extends Applet implements Runnable,ActionListener
{
	Button button;
	TextField text1;
	TextArea text2;
	Socket socket;
	DataInputStream in;
	DataOutputStream out;
	Thread thread;

	//初始化窗口，事件
	public void init()
	{
		setLayout(new BorderLayout());
		button = new Button("send");
		text1 = new TextField(12);
		text2 = new TextArea();
		Panel p = new Panel();
		p.add(text1);
		p.add(button);
		add("Center",text2);
		add("South",p);
		button.addActionListener(this);
	}

	//建立与服务器的socket连接，启动监听线程
	public void start()
	{
		try
		{
			socket = new Socket(this.getCodeBase().getHost(),4331);
			in = new DataInputStream(socket.getInputStream());
			out = new DataOutputStream(socket.getOutputStream());
		}catch(IOException e){}

		if(thread==null)
		{
			thread = new Thread(this);
			thread.setPriority(Thread.MIN_PRIORITY);
			thread.start();
		}
	}

	//处理从服务器监听到的信息
	public void run()
	{
		String s1 = null;
		while(true)
		{
			try
			{
				s1 = in.readUTF();
			}catch(IOException e){}

			if(s1.equals("bye"))
			{
				try
				{
					socket.close();
					break;
				}catch(IOException e){}
			}
			
			text2.append(s1+"\n");
		}
	}
	
	//处理客户端事件，发送信息给服务器
	public void actionPerformed(ActionEvent e)
	{
		if(e.getSource()==button)
		{
			String s = text1.getText();
			if(s!=null)
			{
				try
				{
					out.writeUTF(s);
				}catch(IOException e1){}
			}
			else
			{
				try
				{
					out.writeUTF("请说话");
				}catch(IOException e2){}
			}
		}
	}
};