java分布式开发TCP/IP+BIO(基于消息方式实现系统间的通信)

TCP/IP +BIO
在java中可以基于Socket，SocketServer来实现TCP/IP+BIO的系统间通信，Socket主要用于实现建立连接及网络IO操作，SocketServer主要用于实现服务器端口的监听及SCoket对象的获得 为了满足服务器端能同时接受多个连接发送的请求，通常采用的方法是在accept获取Socket后，将此Socket放入一个线程中处理，通常将此方式称为一连接一线程

客户端代码
package org.cui.TCPIP;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class BioClient {

public static void main(String[] args) throws Exception{
Socket socket = new Socket("127.0.0.1",7888) ;
BufferedReader clientIn = new BufferedReader(new InputStreamReader(System.in)) ;
BufferedReader serverIn  = new BufferedReader(new InputStreamReader(socket.getInputStream())) ;
PrintWriter out = new PrintWriter(socket.getOutputStream() ,true ) ;
boolean flag = true ;
while(flag){
System.out.println("请输入发送信息") ;
String clientSay = clientIn.readLine() ;
if(clientSay == null ||"".equals(clientSay)){
flag = false ;
break ;
}
if("bye".equals(clientSay)){
flag = false ;
break ;
}
out.println(clientSay) ;
System.out.println("服务器："+serverIn.readLine()) ;
}
clientIn.close() ;
serverIn.close() ;
out.close() ;
socket.close() ;
}
}

服务器端代码

package org.cui.TCPIP;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class BioServer {
private ServerSocket serverSocket ;
private Socket socket ;
private int  iClient ;

public BioServer() throws IOException{
serverSocket =  new ServerSocket(7888) ;
iClient = 0  ;
while(true) {
socket = serverSocket.accept() ;
System.out.println("共有多少："+(++iClient)) ;
new Thread(new ClientThread(socket)).start() ;
}
}


public static void main(String[] args) {
try {
new BioServer() ;
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

采用线程  代码：
package org.cui.TCPIP;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class ClientThread implements Runnable {
private Socket client ;
public ClientThread(Socket client) {
this.client = client ;
}
@Override
public void run() {
// TODO Auto-generated method stub
try {
BufferedReader reader = new BufferedReader(new InputStreamReader(client.getInputStream())) ;

boolean flag = true ;
while(flag){
String clientSay = reader.readLine() ;
if (clientSay == null || "".equals(clientSay)) {
flag = false;
break;
}
if ("bye".equals(clientSay)) {
flag = false;
break;
}
System.out.println("client说："+clientSay);
PrintWriter out = new PrintWriter(client.getOutputStream() ,true ) ;
out.println("client端 说的是："+clientSay) ;
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

}

评论

1 楼 songhaikang 2012-08-09  

这叫多线程服务器，怎会和分布式有关呢