写错了 你可别笑我
我是做J2EE的 J2ME不怎么明白
兔子不吃窝边草
服务器程序
package com;
import java.io.*;
import java.net.*;
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
import java.util.*;
import javax.swing.Timer;
public class AppServer implements Runnable{
ServerSocket server;
Socket fromClient;
Thread serverThread;
public AppServer(){
System.out.println("FunChat聊天服务器启动.......");
try{
server = new ServerSocket(1001);
serverThread = new Thread(this);
serverThread.start();
}catch(Exception e){
System.out.println("不能启动线程:"+e.toString());
}
}//AppServer结束
public static void main(String[] args){
new AppServer();
}
public void run() {
try{
while(true){
fromClient =server.accept();
Connect con = new Connect(fromClient);
}
}catch(Exception e){
System.out.println("不能监听客服请求:"+e.toString());
}
}
}
class Connect {
ObjectOutputStream streamToClient;
int ctr = 0;
BufferedReader streamFromClient;
static Vector vector;
static Vector vctrList;
String message="";
static String str = new String("用户列表");
static
{
vector = new Vector(1,1);
vctrList = new Vector(1,1);
vctrList.addElement((String)str);
}
int verify(String mesg)
{
try{
RandomAccessFile RAS = new RandomAccessFile("UsrPwd.txt","r");
int i= 0;
String str="";
while((RAS.getFilePointer())!=(RAS.length())){
str = RAS.readLine();
if(str.equals(mesg)){
ctr = 1;
break;
}
}
RAS.close();
}catch(Exception e){
System.out.println("发生异常:"+e.toString());
}
return ctr;
}
int checkFile(String mesg){
int chk = 1;
try{
RandomAccessFile RS = new RandomAccessFile("UsrPwd.txt","r");
int i =0;
String str="";
String colon = new String(":");
int index = ((String)mesg).lastIndexOf(colon);
String userName = (String)mesg.substring(0, index);
while((RS.getFilePointer())!=(int)(RS.length()))
{
str = RS.readLine();
int index1 = ((String)str).lastIndexOf(colon);
String usrName=(String)str.substring(0,index1);
if(usrName.equals(userName)){
chk = 0;
break;
}
}
RS.close();
}
catch(Exception ee){
System.out.println("发生异常:"+ee.toString());
}
return chk;
}
public Connect(Socket inFromClient){
String msg="";
String mesg = "";
try{
streamFromClient = new BufferedReader(
new InputStreamReader(inFromClient.getInputStream())
);
streamToClient = new ObjectOutputStream(inFromClient.getOutputStream());
msg = streamFromClient.readLine();
if((msg.equals("来自定时器")))
{
streamToClient.writeObject(vector);
streamToClient.writeObject(vctrList);
}else if(msg.equals("登陆信息")){
msg = streamFromClient.readLine();
int ver = verify(msg);
if(ver==1){
String colon = new String(":");
int index =((String)msg).lastIndexOf(colon);
String userName =(String)msg.substring(0,index);
if(!(vctrList.indexOf((String)userName)>0)){
streamToClient.writeObject("欢迎");
vctrList.addElement((String)userName);
}
}else{
streamToClient.writeObject("拒绝登陆");
}
}
else if(msg.equals("注册信息")){
msg = streamFromClient.readLine();
int ret = checkFile(msg);
if(ret==0){
streamToClient.writeObject("用户已经存在");
}
if(ret==1){
FileOutputStream out = new FileOutputStream("UsrPwd.txt",true);
PrintStream p = new PrintStream(out);
p.println();
p.println(msg);
p.close();
streamToClient.writeObject("已注册");
}
}
else if(msg.equals("用户退出")){
String remUser = streamFromClient.readLine();
boolean b = vctrList.removeElement((String)remUser);
}
else{
message = message + msg;
vector.addElement((String)message);
streamToClient.writeObject(vector);
}
}catch(Exception e3){
System.out.println("无发获取客户端的的流对象:"+e3.toString());
}
finally{
try{
inFromClient.close();
}catch(IOException e0){
System.out.println("发生异常:"+e0.toString());
}
}
}
}
