|
package
mytalk;
import java.net.*;
import java.io.*;
import java.util.Scanner;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
public class MyTalk {
public
static final int PORT = 12345;//监听的端口号
public
static void main(String[] args) throws
IOException{
// 控制台输入服务器需要监听的端口号
Scanner inputData = new
Scanner(System.in);
ServerSocket serverSocket = null;
Socket socket = null;
if
(args.length != 1) {
throw
new IllegalArgumentException("Parameter(s): wait or IP address.");
}
String str = args[0];
if
(str.equals("wait")){
serverSocket = new
ServerSocket(PORT);
// 服务器从端口监听连接，监听语句
socket = serverSocket.accept();
} else
if (isIP(str)){
socket = new
Socket(str, PORT);
} else
{
throw
new IllegalArgumentException("Parameter is wrong.");
}
// 创建新线程，用于等待接收客户端发来的消息
(new
MyTalk()).new
ThreadHandleSendAClient(socket);
// 定义输出流，发送消息
DataOutputStream outputToClient = new
DataOutputStream(
socket.getOutputStream());
while
(true) {
// 控制台输入反馈给客户端的信息
String sedServer = inputData.nextLine();
// 将输入的消息发送给客户端
outputToClient.writeUTF(sedServer);
}
}
public
class ThreadHandleSendAClient implements
Runnable {
private
Socket socket;
ThreadHandleSendAClient(Socket socket) {
this.socket = socket;
new
Thread(this).start();
}
public
void run() {
try
{
// 接收客户端发送来的消息并在控制台显示
DataInputStream inputFromClient = new
DataInputStream(
socket.getInputStream());
while
(true) {
String revClient = inputFromClient.readUTF();
System.out.println(revClient);
}
} catch
(IOException ex) {
System.out.println(ex);
}
}
}
private
static boolean isIP(String str) {
String num = "(25[0-5]|2[0-4]\\d|[0-1]\\d{2}|[1-9]?\\d)";
String regex = "^"
+ num + "\\."
+ num + "\\."
+ num + "\\."
+ num + "$";
return
match(regex, str);
}
private
static boolean match(String regex, String str) {
Pattern pattern = Pattern.compile(regex);
Matcher matcher = pattern.matcher(str);
return
matcher.matches();
}
}
| 
