server端
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class shiyan {
ServerSocket ss = null;
Socket s =null;
String str = null;
public void fun() throws IOException{
ss = new ServerSocket(1008);
while(true){
s =ss.accept();
DataInputStream b = new DataInputStream(s.getInputStream());
System.out.println("hehe");
str = b.readUTF();
System.out.println(str);
}}
public static void main(String[] args) throws IOException {
new shiyan().fun();
}}client端
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
public class yanshi {
String str;
Socket s =null;
public void fun() throws IOException, IOException{
s = new Socket("127.0.0.1" , 1008);
DataInputStream a =new DataInputStream(System.in);
str = a.readUTF();
DataOutputStream b = new DataOutputStream(s.getOutputStream());
b.writeUTF(str);
b.flush();
}
public static void main(String[] args) {
try {
new yanshi().fun();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}}}
在client端的system。in里打字
server端接受不到
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;public class Server { public static void main(String[] args) throws IOException {
ServerSocket server = new ServerSocket(1008);
Socket client = server.accept();
BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));
PrintWriter out = new PrintWriter(client.getOutputStream());
while (true) {
String str = in.readLine();
System.out.println(str);
out.println("has receive....");
out.flush();
if (str.equals("end"))
break;
}
client.close();
}
}
Client.java
import java.net.*;
import java.io.*;public class Client {
static Socket server; public static void main(String[] args) throws Exception {
server = new Socket(InetAddress.getLocalHost(), 1008);
BufferedReader in = new BufferedReader(new InputStreamReader(server.getInputStream()));
PrintWriter out = new PrintWriter(server.getOutputStream());
BufferedReader wt = new BufferedReader(new InputStreamReader(System.in)); while (true) {
String str = wt.readLine();
out.println(str);
out.flush();
if (str.equals("end")) {
break;
}
System.out.println(in.readLine());
}
server.close();
}
}
socket这样写是不能担当大任的,要想使用socket还得找mina、qickserver这些东东。