服务器端代码:
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public void server(){
try {
ServerSocket serverSocket = new ServerSocket(8888); //建立服务器端的
套接字,并监听8888端口
Socket socket = serverSocket.accept(); //如果有请求到达,则接受请求,并建立一个新的套接字
InputStream is = socket.getInputStream(); //获取此套接字上的输入流,用于接收消息
//接下来就是获取套接字里的字节流,并转化为
字符串 byte[] bytes = new byte[1024];
int count;
StringBuilder sb = new StringBuilder();
while((count = is.read(bytes)) != -1){
sb.append(new String(bytes, 0, count));
}
is.close();
System.out.println(sb.toString());
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
Server s = new Server();
s.server();
}
}
另附客户端:
import java.io.IOException;
import java.io.OutputStream;
import java.net.InetSocketAddress;
import java.net.Socket;
public class Client {
public void client(){
try {
Socket socket = new Socket(); //建立套接字
socket.connect(new InetSocketAddress("127.0.0.1", 8888)); //连接到指定
IP地址的主机,并指定
端口号接收消息
OutputStream os = socket.getOutputStream(); //获取此连接上的输出流,用于发送数据
os.write(new String("Hello, world!").getBytes()); //将字符串转化为字节数组写入输出流
os.flush();//刷新此输出流,将字节流写入它们预期的目标
os.close(); //关闭连接,否则会报连接重置异常
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
Client c = new Client();
c.client();
}
}
本回答被网友采纳