=================================================================================AGClientBase.java
=================================================================================
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;public class AGClientBase {Socket socket = null;InputStream is = null;OutputStream os = null;String tCode = null;public String testClient(String data) {try {// 建立连接socket = new Socket(getValueByKey.readValue("IpAddrss"), Integer.valueOf(getValueByKey.readValue("Port")).intValue());// 发送数据os = socket.getOutputStream();os.write(data.getBytes());// 接收数据is = socket.getInputStream();byte[] b = new byte[4000];is.read(b);return new String(b).trim();} catch (Exception e) {System.out.println("连接异常,请检查配置文件或对方Socket连接");return null;} finally {try {// 关闭流和连接
    is.close();os.close();socket.close();} catch (Exception e2) {}}}}
======================================================================================================LinkServer.java
======================================================================================================
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket; public class LinkServer { public static void main(String[] args) throws IOException { ServerSocket server = new ServerSocket(10000); while (true) { Socket socket = server.accept();invoke(socket); } } private static void invoke(final Socket socket) throws IOException { new Thread(new Runnable() { public void run() { AGClientBase ag = new AGClientBase();BufferedReader in = null; PrintWriter out = null; try { InputStream inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream();byte[] arry = new byte[4000];while(true){inputStream.read(arry);outputStream.write(ag.testClient(new String(arry)).getBytes());outputStream.flush();socket.close(); } } catch(IOException ex) { // ex.printStackTrace(); } finally { try { in.close(); } catch (Exception e) {} try { out.close(); } catch (Exception e) {} try { socket.close(); } catch (Exception e) {} } } }).start(); }
}
======================================================================================================LinkService.java
======================================================================================================
public interface LinkService {public String reMsg();public String reMsg(String repmsg);
}======================================================================================================getValueByKey
======================================================================================================import java.io.FileInputStream;
import java.io.IOException;
import java.util.Properties;
/*** @author wyyw* 读取配置文件* 根据配置文件中的内容获取要连接的地址** */
public class getValueByKey {private static String filename= "linkconfig.propertes";/*** @author wyyw* @param key 要查询的内容key* @return 根据key查询出来的value** */public static String readValue( String key){Properties props = new Properties();FileInputStream in=null;try{in = new FileInputStream(filename);props.load(in);String value = props.getProperty(key);return value;}catch(Exception e){System.out.println("读取配置文件失败,请检查配置文件 linkconfig.propertes 格式如下");System.out.println("IpAddrss=*.*.*.*");System.out.println("Port=*");return null;}finally{try {in.close();} catch (IOException e) {System.out.println("读取配置文件失败,请检查配置文件 linkconfig.propertes 格式如下");System.out.println("IpAddrss=*.*.*.*");System.out.println("Port=*");}}}
}
======================================================================================================linkconfig.propertes 和项目SRC文件夹同级
======================================================================================================
IpAddrss=127.0.0.1Port=6500