Linuxサーバでsocketリスニングポートを開く
3284 ワード
ステップ1:ローカルでテスト:まずサーバ側のsocketコードです.
クライアントのsocketコード:
テストが成功すると、サーバに配備されます。
package com.serverSocket.main;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static void main(String[] args) throws IOException {
run();
}
public static void run() throws IOException {
try {
ServerSocket serverSocket = new ServerSocket(“ ”);
Socket client = null;
boolean flag = true;
while (flag) {
//System.out.println(" , 。。。。"); , 。
client = serverSocket.accept();
new Thread(new EchoThread(client)).start();
Thread.sleep(500);
}
client.close();
serverSocket.close();
System.out.println(" 。");
} catch (Exception e) {
e.printStackTrace();
}
}
}
class EchoThread implements Runnable {
private Socket client;
public EchoThread(Socket client) {
this.client = client;
}
public void run() {
try {
BufferedReader in = null;
in = new BufferedReader(new InputStreamReader(client.getInputStream(), "utf-8"));
String line = "";
StringBuffer bt = new StringBuffer();
Socket sk = new Socket(" IP", );
OutputStream os = sk.getOutputStream();
System.out.println(sk+":"+os);
while ((line = in.readLine()) != null) {
//line
System.out.println(line);
}
sk.close();
//System.out.println("sk ");
} catch (IOException e1) {
// TODO catch
e1.printStackTrace();
} catch (Exception e) {
// TODO: handle exception
System.out.println("error");
}
}
}
クライアントのsocketコード:
package com.serverSocket.main;
import java.io.*;
import java.net.*;
public class TCPEchoClient {
public static void main(String[] args) throws UnknownHostException, IOException {
Socket s = new Socket("IP",port);
OutputStream os = s.getOutputStream();
String str=" ";
os.write(str.getBytes("UTF-8"));
os.flush();
os.close();
s.close();
}
}