1.客户端接受服务端的消息并打印:
客户端:
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.Socket;
public class Client {
private static final String IP = "localhost";//服务器地址
private static final int PORT = 8000;//服务器端口号
public static void main(String[] args) {
handler();
}
private static void handler() {
//创建一个流套接字,连接到指定主机上的指定端口号
Socket client = null;
try {
while(true){
client = new Socket(IP, PORT);
//取得输入流
InputStream is = client.getInputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(is));
//读取服务器端数据
System.out.println(br.readLine());
br.close();
is.close();
}
}catch (Exception e) {
System.out.println("客户端异常:" + e.getMessage());
}finally{
if(client != null){
try {
client.close();
} catch (IOException e) {
System.out.println("客户端异常:" + e.getMessage());
}
}
}
}
}
服务端:
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class Server {
private static final int PORT = 8000;//监听的端口号
public static void main(String[] args) {
Server server = new Server();
server.init();
}
private void init(){
try {
ServerSocket serverSocket = new ServerSocket(PORT);
while(true){
Socket client = serverSocket.accept();
//一个客户端连接就开户一个线程处理
new Thread(new HandlerThread(client)).start();
}
} catch (IOException e) {
System.out.println("服务器异常:" + e.getMessage());
}
}
private class HandlerThread implements Runnable{
private Socket client;
public HandlerThread(Socket client) {
this.client = client;
}
@Override
public void run() {
try {
//取得输出流
OutputStream os = client.getOutputStream();
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(os));
//输入要输出给客户端的内容
Scanner sc = new Scanner(System.in);
bw.write(sc.nextLine());
bw.close();
} catch (IOException e) {
System.out.println("服务器异常:" + e.getMessage());
}finally{
if(client != null){
try {
client.close();
} catch (IOException e) {
client = null;
System.out.println("服务器异常:" + e.getMessage());
}
}
}
}
}
}
2.服务端接受客户端的消息并打印:
客户端:
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.Scanner;
public class Client {
private static final String IP = "localhost";//服务器地址
private static final int PORT = 8000;//服务器端口号
public static void main(String[] args) {
handler();
}
private static void handler() {
//创建一个流套接字,连接到指定主机上的指定端口号
Socket client = null;
try {
while(true){
client = new Socket(IP, PORT);
//取得输出流
OutputStream os = client.getOutputStream();
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(os));
//输入要发送到服务端的消息
Scanner sc = new Scanner(System.in);
bw.write(sc.nextLine());
bw.close();
os.close();
}
}catch (Exception e) {
System.out.println("客户端异常:" + e.getMessage());
}finally{
if(client != null){
try {
client.close();
} catch (IOException e) {
System.out.println("客户端异常:" + e.getMessage());
}
}
}
}
}
服务端:
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
private static final int PORT = 8000;//监听的端口号
public static void main(String[] args) {
Server server = new Server();
server.init();
}
private void init(){
try {
ServerSocket serverSocket = new ServerSocket(PORT);
while(true){
Socket client = serverSocket.accept();
//一个客户端连接就开户一个线程处理
new Thread(new HandlerThread(client)).start();
}
} catch (IOException e) {
System.out.println("服务器异常:" + e.getMessage());
}
}
private class HandlerThread implements Runnable{
private Socket client;
public HandlerThread(Socket client) {
this.client = client;
}
@Override
public void run() {
try {
//取得输入流
InputStream is = client.getInputStream();
BufferedReader bw = new BufferedReader(new InputStreamReader(is));
//读取客户端发送来的数据
System.out.println(bw.readLine());
bw.close();
} catch (IOException e) {
System.out.println("服务器异常:" + e.getMessage());
}finally{
if(client != null){
try {
client.close();
} catch (IOException e) {
client = null;
System.out.println("服务器异常:" + e.getMessage());
}
}
}
}
}
}
分享到:
相关推荐
JAVA Socket通信示例,包含单工、半双工、全双工通信示例.zip
电信设备-单工移动通信设备声控开关.zip
Simplex 单工通信 Full-Duplex 全双工通信 TransmitFile 双向文件传输 大文件传输过程发现接收端和发送端得到的文件大小不一致,而且收到的文件大小也在变,几个M的mp3没什么影响,但是如果是500m视频影响进度条。...
电子政务-单工通信无线电台的自动发射开关.zip
Java远程消息传送器 <br>功能要求: <br>桌面窗口应用程序; <br>包括多个发送端和一个接收端; <br>多用户使用发送端通过网络连接接收端; <br>用户输入文字消息,然后发送给接收端,接收端将消息...
python socket隧道转发,单工通信
商业编程-源码-单工语音聊天室.zip
嵌入式开发小软件实用嵌入式开发小软件实用嵌入式开发小软件实用嵌入式开发小软件实用嵌入式开发小软件实用
高频无线通信的设计方案集 实现单工呼叫,40M调频发射,可发送短信,可单向通话
matlab开发-单工瞬变稳定码。电力系统暂态稳定简码
单片机-单工无线呼叫系统设计资料
单片机-单工无线发射接收系统资料
matlab开发-单工经济调度。程序计算经济成本和单位的生成,简单的lambda迭代法,无损失
matlab开发-单工经济调度.zip.zip
电信设备-单工信道双工转换器.zip
matlab开发-单工双刀多路径衰减通道。这个mfile演示了一个简单的双路瑞利多径衰落信道。
matlab开发-单工语音识别无ThereDSSRU。不再需要在主脚本中加载多个.wav文件
模拟单工通信系统-北京交通大学电子系统课程设计-毕业论文.doc