案例一：
需求：
1.客户端：发送数据，接收服务器反馈
2.服务器：接收数据，给出反馈
分析：
客户端步骤：
1.创建客户端Client的Socket对象
2.发送数据
3.接受服务端Service的反馈，也就是读数据
4.释放资源
package Demo042003;
/*客户端
1.创建客户端Client的Socket对象
2.发送数据
3.接受服务端Service的反馈，也就是读数据
4.释放资源
* */
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
public class ClientTcp {
public static void main(String[] args) throws IOException {
//创建客户端Client的Socket对象
Socket s=new Socket("127.0.0.1",54638);
//发送数据
OutputStream ops = s.getOutputStream();
ops.write("最美不过姑娘你".getBytes());
//接受服务端Service的反馈，也就是读数据
InputStream ips = s.getInputStream();
byte[]bytes=new byte[1024];
int len=ips.read(bytes);
System.out.println("服务器反馈是"+new String(bytes,0,len));
//释放资源
s.close();
}
}
服务端步骤：
1.创建服务端Server的ServerSocket对象
2.接收数据
3.接收成功后发出反馈，也就是写数据
4.释放资源
package Demo042003;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
/*服务端
1.创建服务端Server的ServerSocket对象
2.接收数据
3.接收成功后发出反馈，也就是写数据
4.释放资源
* */
public class ServerTcp {
public static void main(String[] args) throws IOException {
//创建服务端Server的ServerSocket对象
ServerSocket ss = new ServerSocket(54638);
//accept() 侦听要连接到此套接字并接受它返回一个Soket对象
Socket s = ss.accept();
//接收数据
InputStream ips = s.getInputStream();
byte[] bytes = new byte[1024];
int len = ips.read(bytes);
System.out.println("接收到的数据是\r\n" + new String(bytes, 0, len));
//接收成功后发出反馈，也就是写数据
OutputStream ops = s.getOutputStream();
ops.write("已接受数据".getBytes());
//释放资源
//ss.close();
}
}
疑问：为什么服务器接收数据时不能使用while循环接收？在使用循环接受的话会出现客户端无法收到反馈
已找到原因：客户端发送完毕后服务端还在等待接收消息，所以无法给出反馈，需要在客户端发送数据完成后使用
//定义发送完毕标记
s.shutdownOutput();
shutdownOutput()` 禁用此套接字的输出流。
使用后服务端将不再等待接收消息，继续向下执行
案例二
需求：
1.客户端：数据来源于键盘输入，直到输入的数据是over，发送数据结束
2.服务器：接收数据在控制台输出，并给出反馈
分析：与案例一基本相同，只是增加了键盘录入的部分
客户端
package Demo042005;
import java.io.*;
import java.net.Socket;
public class ClientDemo {
public static void main(String[] args) throws IOException {
//创建Socket对象
Socket s=new Socket("cy",12345);
//封装键盘录入数据
BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
//封装输出流
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
String line;
while ((line=br.readLine())!=null){
if ("over".equals(line)){
break;
}
//获取输出流对象
// OutputStream ops = s.getOutputStream();
// ops.write(line.getBytes());
bw.write(line);
bw.newLine();
bw.flush();
}
//获取反馈
InputStream ips = s.getInputStream();
byte[]bytes=new byte[1024];
int len;
while ((len=ips.read(bytes))!=-1) {
System.out.println("服务器反馈是"+new String(bytes,0,len));
}
//释放资源
s.close();
}
}
服务端
package Demo042005;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerDemo {
public static void main(String[] args) throws IOException {
//创建ServerSocket对象
ServerSocket ss=new ServerSocket(12345);
//监听
Socket s = ss.accept();
//获取数据
BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
String line;
while ((line=br.readLine())!=null){
System.out.println(line);
}
//接收完毕给出反馈
OutputStream ops = s.getOutputStream();
ops.write("已接收数据".getBytes());
//释放资源
ss.close();
}
}
案例三
需求:
客户端：数据来源于键盘录入，直到输入的数据是886，发送数据停止
服务端：将接收到的数据写入文本文件
客户端
package Demo042101;
import java.io.*;
import java.net.Socket;
public class ClientDemo {
public static void main(String[] args) throws IOException {
//创建Socket对象
Socket s=new Socket("cy",12345);
//封装键盘录入数据
BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
//封装写数据
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
String line;
while ((line=br.readLine())!=null){
if ("over".equals(line)){
break;
}
bw.write(line);
bw.newLine();
bw.flush();
}
}
}
服务端
package Demo042101;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerDemo {
public static void main(String[] args) throws IOException {
//创建ServerSocket对象
ServerSocket ss=new ServerSocket(12345);
//监听并获取Socket对象
Socket s = ss.accept();
//创建要写入的文本文件对象
FileWriter fw=new FileWriter(new File("E:\\server.txt"));
// //创建字符输入流对象
// BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
//读取数据
BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
String line;
while ((line=br.readLine())!=null){
fw.write(line);
fw.flush();
fw.close();
}
}
}
案例四
需求：
客户端：数据来自于文本文件
服务端：接收到的数据写入文本文件
客户端
package Demo042102;
import java.io.*;
import java.net.Socket;
public class ClientDemo {
public static void main(String[] args) throws IOException {
//创建Socket对象
Socket s=new Socket("cy",12345);
//创建读取文件对象
BufferedReader br=new BufferedReader(new FileReader(new File("E:\\abc.txt")));
//创建写入对象
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
//读取数据
String line;
while ((line=br.readLine())!=null){
bw.write(line);
bw.newLine();
bw.flush();
}
}
}
服务端
package Demo042102;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerDemo {
public static void main(String[] args) throws IOException {
//创建ServerSoket对象
ServerSocket ss=new ServerSocket(12345);
//监听并返回Socket对象
Socket s = ss.accept();
//创建读取文件对象
BufferedWriter bw=new BufferedWriter(new FileWriter("E:\\Server.txt"));
BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
String line;
while ((line=br.readLine())!=null){
bw.write(line);
bw.newLine();
bw.flush();
}
}
}
案例五
需求：
客户端：数据来自于文本文件，并接收反馈
服务端：接收到的数据写入文本文件，并给出反馈
客户端
package Demo042102;
import java.io.*;
import java.net.Socket;
public class ClientDemo {
public static void main(String[] args) throws IOException {
//创建Socket对象
Socket s=new Socket("cy",12345);
//创建读取文件对象
BufferedReader br=new BufferedReader(new FileReader(new File("E:\\abc.txt")));
//创建写入对象
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
//读取数据
String line;
while ((line=br.readLine())!=null){
bw.write(line);
bw.newLine();
bw.flush();
}
//结束
s.shutdownOutput();
//接受反馈
BufferedReader brclinet=new BufferedReader(new InputStreamReader(s.getInputStream()));
String data;
data=brclinet.readLine();
System.out.println("服务器："+data);
}
}
服务端
package Demo042102;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerDemo {
public static void main(String[] args) throws IOException {
//创建ServerSoket对象
ServerSocket ss=new ServerSocket(12345);
//监听并返回Socket对象
Socket s = ss.accept();
//创建读取文件对象
BufferedWriter bw=new BufferedWriter(new FileWriter("E:\\Server.txt"));
BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
String line;
while ((line=br.readLine())!=null){
bw.write(line);
bw.newLine();
bw.flush();
}
//给出反馈
BufferedWriter bwserver=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
bwserver.write("已收到数据");
bwserver.newLine();
bwserver.flush();
}
}
案例六
需求：
客户端：数据来自于文本文件，并接收反馈
服务端：接收到的数据写入文本文件，并给出反馈，代码用线程进行封装，为每一个客户端开启一个线程
ServerThread类
package Demo042103;
import java.io.*;
import java.net.Socket;
public class ServerThread implements Runnable {
private Socket s;
public ServerThread(Socket s) {
this.s=s;
}
@Override
public void run() {
try {
//写入数据
BufferedWriter bw=new BufferedWriter(new FileWriter("E:\\Server.txt"));
BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
String line;
while ((line=br.readLine())!=null){
bw.write(line);
bw.newLine();
bw.flush();
}
//给出反馈
BufferedWriter bwServer=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
bwServer.write("上传文件完成");
bwServer.newLine();
bwServer.flush();
} catch (IOException e) {
e.printStackTrace();
}
}
}
客户端
package Demo042103;
import java.io.*;
import java.net.Socket;
public class ClientDemo {
public static void main(String[] args) throws IOException {
//创建Socket对象
Socket s=new Socket("cy",12345);
//创建读取文件对象
BufferedReader br=new BufferedReader(new FileReader(new File("E:\\abc.txt")));
//创建写入对象
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
//读取数据
String line;
while ((line=br.readLine())!=null){
bw.write(line);
bw.newLine();
bw.flush();
}
//结束
s.shutdownOutput();
//接受反馈
BufferedReader brclinet=new BufferedReader(new InputStreamReader(s.getInputStream()));
String data;
data=brclinet.readLine();
System.out.println("服务器："+data);
}
}
服务端
package Demo042103;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerDemo {
public static void main(String[] args) throws IOException {
//创建ServerSoket对象
ServerSocket ss=new ServerSocket(12345);
while (true){
//监听并返回Socket对象
Socket s = ss.accept();
//创建线程,为每一个客户端开启一个线程
new Thread(new ServerThread(s)).start();
}
}
} 我构建了两个需要相互通信和发送文件的Rails应用程序。例如，一个Rails应用程序会发送请求以查看其他应用程序数据库中的表。然后另一个应用程序将呈现该表的json并将其发回。我还希望一个应用程序将存储在其公共(public)目录中的文本文件发送到另一个应用程序的公共(public)目录。我从来没有做过这样的事情，所以我什至不知道从哪里开始。任何帮助，将不胜感激。谢谢! 最佳答案 无论Rails是什么，几乎所有Web应用程序都有您的要求，大多数现代Web应用程序都需要相互通信。但是有一个小小的理解需要你坚持下去，网站不应直接访问彼此
我真的很习惯使用Ruby编写以下代码:my_hash={}my_hash['test']=1Java中对应的数据结构是什么？ 最佳答案 HashMapmap=newHashMap();map.put("test",1);我假设？ 关于java-等价于Java中的RubyHash，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/questions/22737685/
我正在尝试使用boilerpipe来自JRuby。我看过guide从JRuby调用Java，并成功地将它与另一个Java包一起使用，但无法弄清楚为什么同样的东西不能用于boilerpipe。我正在尝试基本上从JRuby中执行与此Java等效的操作:URLurl=newURL("http://www.example.com/some-location/index.html");Stringtext=ArticleExtractor.INSTANCE.getText(url);在JRuby中试过这个:require'java'url=java.net.URL.new("http://www
我只想对我一直在思考的这个问题有其他意见，例如我有classuser_controller和classuserclassUserattr_accessor:name,:usernameendclassUserController//dosomethingaboutanythingaboutusersend问题是我的User类中是否应该有逻辑user=User.newuser.do_something(user1)oritshouldbeuser_controller=UserController.newuser_controller.do_something(user1,user2)我
什么是ruby的rack或python的Java的wsgi？还有一个路由库。 最佳答案 来自Python标准PEP333:Bycontrast,althoughJavahasjustasmanywebapplicationframeworksavailable,Java's"servlet"APImakesitpossibleforapplicationswrittenwithanyJavawebapplicationframeworktoruninanywebserverthatsupportstheservletAPI.ht
这篇文章是继上一篇文章“Observability：从零开始创建Java微服务并监控它（一）”的续篇。在上一篇文章中，我们讲述了如何创建一个Javaweb应用，并使用Filebeat来收集应用所生成的日志。在今天的文章中，我来详述如何收集应用的指标，使用APM来监控应用并监督web服务的在线情况。源码可以在地址 https://github.com/liu-xiao-guo/java_observability 进行下载。摄入指标指标被视为可以随时更改的时间点值。当前请求的数量可以改变任何毫秒。你可能有1000个请求的峰值，然后一切都回到一个请求。这也意味着这些指标可能不准确，你还想提取最小/
HashMap中为什么引入红黑树，而不是AVL树呢1.概述开始学习这个知识点之前我们需要知道，在JDK1.8以及之前，针对HashMap有什么不同。JDK1.7的时候，HashMap的底层实现是数组+链表JDK1.8的时候，HashMap的底层实现是数组+链表+红黑树我们要思考一个问题，为什么要从链表转为红黑树呢。首先先让我们了解下链表有什么不好？？？2.链表上述的截图其实就是链表的结构，我们来看下链表的增删改查的时间复杂度增：因为链表不是线性结构，所以每次添加的时候，只需要移动一个节点，所以可以理解为复杂度是N(1)删：算法时间复杂度跟增保持一致查：既然是非线性结构，所以查询某一个节点的时候
本文主要介绍在使用Selenium进行自动化测试或者任务时，对于使用了iframe的页面，如何定位iframe中的元素文章目录场景描述解决方案具体代码场景描述当我们在使用Selenium进行自动化测试的时候，可能会遇到一些界面或者窗体是使用HTML的iframe标签进行承载的。对于iframe中的标签，如果直接查找是无法找到的，会抛出没有找到元素的异常。比如近在咫尺的例子就是，CSDN的登录窗体就是使用的iframe，大家可以尝试通过F12开发者模式查看到的tag_name,class_name,id或者xpath来定位中的页面元素，会抛出NoSuchElementException异常。解决
最近在学习CAN，记录一下，也供大家参考交流。推荐几个我觉得很好的CAN学习，本文也是在看了他们的好文之后做的笔记首先是瑞萨的CAN入门，真的通透；秀！靠这篇我竟然2天理解了CAN协议！实战STM32F4CAN！原文链接：https://blog.csdn.net/XiaoXiaoPengBo/article/details/116206252CAN详解（小白教程）原文链接：https://blog.csdn.net/xwwwj/article/details/105372234一篇易懂的CAN通讯协议指南1一篇易懂的CAN通讯协议指南1-知乎(zhihu.com)视频推荐CAN总线个人知识总
MIMO技术的优缺点优点通过下面三个增益来总体概括：阵列增益。阵列增益是指由于接收机通过对接收信号的相干合并而活得的平均SNR的提高。在发射机不知道信道信息的情况下，MIMO系统可以获得的阵列增益与接收天线数成正比复用增益。在采用空间复用方案的MIMO系统中，可以获得复用增益，即信道容量成倍增加。信道容量的增加与min(Nt,Nr)成正比分集增益。在采用空间分集方案的MIMO系统中，可以获得分集增益，即可靠性性能的改善。分集增益用独立衰落支路数来描述，即分集指数。在使用了空时编码的MIMO系统中，由于接收天线或发射天线之间的间距较远，可认为它们各自的大尺度衰落是相互独立的，因此分布式MIMO