server端
import java.io.*;
import java.net.*;
public class EchoServer1 extends Thread {
Socket socket1;
public EchoServer1( Socket s) {
socket1=s;
start();
}
public void run() {
try {
BufferedReader in=new BufferedReader(new InputStreamReader(socket1.getInputStream()));
PrintWriter out =new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket1.getOutputStream())), true);
byte[] sa=new byte[50];
String stra=null;
String str=null;
str = new String(sa,0,5,"gb2312");
//stra = new String(straa.getBytes("iso8859-1"),"gb2312");
// String str=in.readLine();
System.out.println("Server receives " +str);
out.write("Server returns back "+str);
out.flush();
in.close();
out.close();
}
catch (IOException e) {
System.err.println("IO Exception");
}
finally {
try {
socket1.close();
}
catch (IOException e) {
System.err.println("Socket not closed");
}
}
}static final int PORT = 8082;
public static void main(String[] args) throws IOException {
ServerSocket s = new ServerSocket(PORT);
System.out.println("Server Started");
try {
while(true) {
Socket socket1 = s.accept();
try {
new EchoServer1(socket1);
}
catch(Exception e) {
socket1.close();
}
}
}
finally {
s.close();
}
}
}client端
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
public class client1 extends Thread{ int threadNumber;
Socket socket1;
public client1(int i,Socket s){
System.out.println("making:"+i);
threadNumber=i;
socket1=s;
start();
}
public void run(){
try{
PrintWriter out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket1.getOutputStream())),true);
int i=0;
out.print("datafrom client:"+threadNumber+"="+i);
out.flush();
BufferedReader in=new BufferedReader(new InputStreamReader(socket1.getInputStream()));
System.out.println(in.readLine()+"liu");
}
catch(IOException e){
try {
socket1.close();
} catch (IOException e1) {
// TODO 自动生成 catch 块
e1.printStackTrace();
}
}
}
public static void main(String[] args) throws IOException{
new client1(1,new Socket("10.0.1.75",8082));
new client1(2,new Socket("10.0.1.75",8082));
new client1(3,new Socket("10.0.1.75",8082)); }}
请问怎么办 谢谢
import java.io.*;
import java.net.*;
public class EchoServer1 extends Thread {
Socket socket1;
public EchoServer1( Socket s) {
socket1=s;
start();
}
public void run() {
try {
BufferedReader in=new BufferedReader(new InputStreamReader(socket1.getInputStream()));
PrintWriter out =new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket1.getOutputStream())), true);
byte[] sa=new byte[50];
String stra=null;
String str=null;
str = new String(sa,0,5,"gb2312");
//stra = new String(straa.getBytes("iso8859-1"),"gb2312");
// String str=in.readLine();
System.out.println("Server receives " +str);
out.write("Server returns back "+str);
out.flush();
in.close();
out.close();
}
catch (IOException e) {
System.err.println("IO Exception");
}
finally {
try {
socket1.close();
}
catch (IOException e) {
System.err.println("Socket not closed");
}
}
}static final int PORT = 8082;
public static void main(String[] args) throws IOException {
ServerSocket s = new ServerSocket(PORT);
System.out.println("Server Started");
try {
while(true) {
Socket socket1 = s.accept();
try {
new EchoServer1(socket1);
}
catch(Exception e) {
socket1.close();
}
}
}
finally {
s.close();
}
}
}client端
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
public class client1 extends Thread{ int threadNumber;
Socket socket1;
public client1(int i,Socket s){
System.out.println("making:"+i);
threadNumber=i;
socket1=s;
start();
}
public void run(){
try{
PrintWriter out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket1.getOutputStream())),true);
int i=0;
out.print("datafrom client:"+threadNumber+"="+i);
out.flush();
BufferedReader in=new BufferedReader(new InputStreamReader(socket1.getInputStream()));
System.out.println(in.readLine()+"liu");
}
catch(IOException e){
try {
socket1.close();
} catch (IOException e1) {
// TODO 自动生成 catch 块
e1.printStackTrace();
}
}
}
public static void main(String[] args) throws IOException{
new client1(1,new Socket("10.0.1.75",8082));
new client1(2,new Socket("10.0.1.75",8082));
new client1(3,new Socket("10.0.1.75",8082)); }}
请问怎么办 谢谢
http://www.regexlab.com/zh/encoding.htm