JAVA Socket示例
2008-08-01 15:13
253 查看
//Server.java
import java.net.*;
import java.io.*;
public class Server{
public static void main(String[] args)throws IOException {
ServerSocket ss=new ServerSocket(8899);
try{
while(true){
System.out.println("Listening on port 8899...");
Socket so=ss.accept();
new ServerThread(so).start();
}
}catch(Exception e){System.err.println(e);}
finally{
try{
ss.close();
}catch(Exception e){
System.err.println("ServerSocket not closeed!");
}
}
}
}
class ServerThread extends Thread{
private Socket so;
public ServerThread(Socket s){
so=s;
}
public void run(){
try{
BufferedReader in=new BufferedReader(new InputStreamReader(so.getInputStream()));
PrintWriter out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(so.getOutputStream())),true);
String str;
while((str=in.readLine())!=null){
System.out.println("Got message: "+str);
out.println("Server got it: "+str);
}
}catch(Exception e){System.err.println(e);}
}
}
//Client.java
import java.net.*;
import java.io.*;
public class Client extends Thread {
public void run() {
try {
InetAddress adds = InetAddress.getByName(null);
Socket so = new Socket(adds, 8899);
BufferedReader in = new BufferedReader(new InputStreamReader(so
.getInputStream()));
PrintWriter out = new PrintWriter(new BufferedWriter(
new OutputStreamWriter(so.getOutputStream())), true);
int i = 0;
while (true) {
Thread.sleep(100);
out.println("Hello, MOTO " + ++i);
String str = in.readLine();
System.out.println("Got return message: " + str);
}
} catch (Exception e) {
} finally {
System.out.println("Over :=)");
}
}
public static void main(String[] args) {
for (int i = 0; i < 10; i++) {
Client c = new Client();
c.start();
}
}
}
import java.net.*;
import java.io.*;
public class Server{
public static void main(String[] args)throws IOException {
ServerSocket ss=new ServerSocket(8899);
try{
while(true){
System.out.println("Listening on port 8899...");
Socket so=ss.accept();
new ServerThread(so).start();
}
}catch(Exception e){System.err.println(e);}
finally{
try{
ss.close();
}catch(Exception e){
System.err.println("ServerSocket not closeed!");
}
}
}
}
class ServerThread extends Thread{
private Socket so;
public ServerThread(Socket s){
so=s;
}
public void run(){
try{
BufferedReader in=new BufferedReader(new InputStreamReader(so.getInputStream()));
PrintWriter out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(so.getOutputStream())),true);
String str;
while((str=in.readLine())!=null){
System.out.println("Got message: "+str);
out.println("Server got it: "+str);
}
}catch(Exception e){System.err.println(e);}
}
}
//Client.java
import java.net.*;
import java.io.*;
public class Client extends Thread {
public void run() {
try {
InetAddress adds = InetAddress.getByName(null);
Socket so = new Socket(adds, 8899);
BufferedReader in = new BufferedReader(new InputStreamReader(so
.getInputStream()));
PrintWriter out = new PrintWriter(new BufferedWriter(
new OutputStreamWriter(so.getOutputStream())), true);
int i = 0;
while (true) {
Thread.sleep(100);
out.println("Hello, MOTO " + ++i);
String str = in.readLine();
System.out.println("Got return message: " + str);
}
} catch (Exception e) {
} finally {
System.out.println("Over :=)");
}
}
public static void main(String[] args) {
for (int i = 0; i < 10; i++) {
Client c = new Client();
c.start();
}
}
}
相关文章推荐
- Java Socket长连接示例代码
- Java网络编程(Socket示例)
- JAVA Socket & UDP 示例
- Java 使用 Socket 池 读写 示例
- android客户端和java服务端之间用socket来传输图片(示例代码)
- ZMQ.Socket JAVA 代码示例
- JAVA 网络编程(3) SOCKET 非阻塞NIO 处理HTTP请求示例
- 简单的Java Socket示例
- Java 使用 Socket 池 读写 示例
- java基于socket传输zip文件功能示例
- java TCP&UDP socket编程示例
- java实现socket从服务器连续获取消息的示例
- JAVA套接字(Socket)101七天系列—第四天【一个简单示例】
- JAVA套接字(Socket)101七天系列—第五天【一个多线程的示例】
- 简单的java socket 示例
- Java基于Socket实现简单的多线程回显服务器功能示例
- 简单的java socket 示例
- JAVA 网络编程(2) SOCKET 非阻塞NIO示例
- java TCPSocket编程 简单示例3
- java UDPSocket 简单示例