服务器发送和接收部分 package com.xll.chat;import java.io.DataInput;import java.io.DataInputStream;import java.io.IOException;import java.net.Socket;public class ServerGet extends Thread {static DataInputStream input=null;static So
package com.xll.chat;
import java.io.DataInput;
import java.io.DataInputStream;
import java.io.IOException;
import java.net.Socket;
public class ServerGet extends Thread {
static DataInputStream input=null;
static Socket socket=null;
public ServerGet(Socket socket){
this.socket=socket;
}
public void run(){
try {
input=new DataInputStream(socket.getInputStream());
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
while(true){
try {
System.out.println(input.readUTF());
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
package com.xll.chat;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.Scanner;
public class ServerSend extends Thread{
static Scanner inputs=new Scanner(System.in);
static DataOutputStream out=null;
static Socket sockek=null;
public ServerSend(Socket socket){
this.sockek=socket;
}
public int run(String name){
try {
String message=inputs.next();
if(message=="0"){
return 1;
}else{
out=new DataOutputStream(sockek.getOutputStream());
out.writeUTF("好友"+name+"给你发来消息:"+message);
return 2;
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return 0;
}
}
