如何使用Java实现两台PC机之间的串口通信
使用Java语言实现两台电脑之间的串口通信,一端进行发送,另一端能够接受。回答出来,我会继续加分的。两台电脑之间采用RS232或者RS485进行连线,大家帮帮忙,谢谢各位...
使用Java语言实现两台电脑之间的串口通信,一端进行发送,另一端能够接受。回答出来,我会继续加分的。
两台电脑之间采用RS232或者RS485进行连线,大家帮帮忙,谢谢各位大侠。 有没有人知道如何使用JAVA实现两机串口通信呀?求求各位,帮帮忙 展开
两台电脑之间采用RS232或者RS485进行连线,大家帮帮忙,谢谢各位大侠。 有没有人知道如何使用JAVA实现两机串口通信呀?求求各位,帮帮忙 展开
展开全部
//SocketClient
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
import org.apache.log4j.Logger;
import com.sitinspring.server.ResponseThread;
/**
* Socket客户端
* @author: sitinspring(junglesong@gmail.com)
* @date: 2007-11-16
*/
public class SocketClient{
private static Logger logger = Logger.getLogger(ResponseThread.class);
public static void main(String[] args){
try {
Socket socket=new Socket("127.0.0.1",2009);
logger.info("客户端向服务器发起请求.");
try {
InputStream inStream = socket.getInputStream();
OutputStream outStream = socket.getOutputStream();
Scanner in = new Scanner(inStream);
PrintWriter out = new PrintWriter(outStream);
out.println("地震高岗 一派溪山千古秀");
out.flush();
while (in.hasNextLine()) {
String line = in.nextLine();
logger.info("客户端获得响应文字="+ line);
}
} finally {
socket.close();
}
} catch (IOException ex) {
ex.printStackTrace();
}
}
}
//Member
import java.util.Comparator;
public class Member implements Comparable {
private String name;
private int age;
public Member(String name, int age) {
this.name = name;
this.age = age;
}
public int compareTo(Object obj) {
Member another = (Member) obj;
//return this.name.compareTo(another.name);
return this.age-another.age;
}
public String toString(){
return "Member name="+name+" age="+age;
}
}
//Main
import java.util.Arrays;
import java.util.List;
public class Main{
public static void main(String[] args){
String[] arr={"Andy","Bill","Cindy","Dell"};
List<String> ls=Arrays.asList(arr);
for(String str:ls){
System.out.println(str);
}
/*List<String> ls=new ArrayList<String>();
ls.add("Felex");
ls.add("Gates");
ls.add("Andy");
ls.add("Bill");
ls.add("Cindy");
ls.add("Dell");
Object[] arr=ls.toArray();
for(Object obj:arr){
System.out.println((Object)obj);
}*/
/*Collections.sort(ls);
for(Member member:ls){
System.out.println(member);
}*/
/*Member member=new Member("Edin",28);
ls.remove(member);
ls.remove(2);
ls.clear();
List ls2=new ArrayList();*/
/*for(Member member:ls){
// member
}*/
/*for(int i=0;i<ls.size();i++){
Member member=ls.get(i);
}*/
/*for(Iterator it=ls.iterator();it.hasNext();){
Member member=(Member)it.next();
}
List<Member> ls2=new ArrayList<Member>();
ls2.add(new Member("Felex",21));
ls2.add(new Member("Gates",23));
ls.addAll(ls2);
ls2.*/
/*List ls3=null;
System.out.println(ls3.isEmpty());*/
/*List ls3=null;
System.out.println(ls2.isEmpty());*/
/*ls.
ls.indexOf(o)
ls.contains(o)*/
//ls2.add(1);
}
}
//ResponseThread 这个是server的先启动client(服务器)再启动它。上面三个类是client放在一个文件夹中
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
import org.apache.log4j.Logger;
/**
* 响应线程,建立ServerSocket响应客户端Socket请求
* @author: sitinspring(junglesong@gmail.com)
* @date: 2007-11-16
*/
public class ResponseThread implements Runnable {
private static Logger logger = Logger.getLogger(ResponseThread.class);
// 用于与客户端通信的Socket
private Socket incomingSocket;
public ResponseThread(Socket incomingSocket) {
this.incomingSocket = incomingSocket;
}
public void run() {
try {
try {
// 输入流
InputStream inStream = incomingSocket.getInputStream();
// 输出流
OutputStream outStream = incomingSocket.getOutputStream();
Scanner in = new Scanner(inStream);
PrintWriter out = new PrintWriter(outStream,true);
while (in.hasNextLine()) {
String line = in.nextLine();
logger.info("从客户端获得文字:"+line);
String responseLine=line+" 门朝大海 三河合水万年流";
out.println(responseLine);
logger.info("向客户端送出文字:"+responseLine);
}
} finally {
incomingSocket.close();
}
} catch (IOException ex) {
ex.printStackTrace();
}
}
public static void main(String[] args) {
try {
ServerSocket socket=new ServerSocket(2009);
logger.info("开始监听");
while(true){
Socket incomingSocket=socket.accept();
logger.info("获得来自"+incomingSocket.getInetAddress()+"的请求.");
ResponseThread responseThread=new ResponseThread(incomingSocket);
Thread thread=new Thread(responseThread);
thread.start();
}
} catch (IOException ex) {
ex.printStackTrace();
}
}
}
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
import org.apache.log4j.Logger;
import com.sitinspring.server.ResponseThread;
/**
* Socket客户端
* @author: sitinspring(junglesong@gmail.com)
* @date: 2007-11-16
*/
public class SocketClient{
private static Logger logger = Logger.getLogger(ResponseThread.class);
public static void main(String[] args){
try {
Socket socket=new Socket("127.0.0.1",2009);
logger.info("客户端向服务器发起请求.");
try {
InputStream inStream = socket.getInputStream();
OutputStream outStream = socket.getOutputStream();
Scanner in = new Scanner(inStream);
PrintWriter out = new PrintWriter(outStream);
out.println("地震高岗 一派溪山千古秀");
out.flush();
while (in.hasNextLine()) {
String line = in.nextLine();
logger.info("客户端获得响应文字="+ line);
}
} finally {
socket.close();
}
} catch (IOException ex) {
ex.printStackTrace();
}
}
}
//Member
import java.util.Comparator;
public class Member implements Comparable {
private String name;
private int age;
public Member(String name, int age) {
this.name = name;
this.age = age;
}
public int compareTo(Object obj) {
Member another = (Member) obj;
//return this.name.compareTo(another.name);
return this.age-another.age;
}
public String toString(){
return "Member name="+name+" age="+age;
}
}
//Main
import java.util.Arrays;
import java.util.List;
public class Main{
public static void main(String[] args){
String[] arr={"Andy","Bill","Cindy","Dell"};
List<String> ls=Arrays.asList(arr);
for(String str:ls){
System.out.println(str);
}
/*List<String> ls=new ArrayList<String>();
ls.add("Felex");
ls.add("Gates");
ls.add("Andy");
ls.add("Bill");
ls.add("Cindy");
ls.add("Dell");
Object[] arr=ls.toArray();
for(Object obj:arr){
System.out.println((Object)obj);
}*/
/*Collections.sort(ls);
for(Member member:ls){
System.out.println(member);
}*/
/*Member member=new Member("Edin",28);
ls.remove(member);
ls.remove(2);
ls.clear();
List ls2=new ArrayList();*/
/*for(Member member:ls){
// member
}*/
/*for(int i=0;i<ls.size();i++){
Member member=ls.get(i);
}*/
/*for(Iterator it=ls.iterator();it.hasNext();){
Member member=(Member)it.next();
}
List<Member> ls2=new ArrayList<Member>();
ls2.add(new Member("Felex",21));
ls2.add(new Member("Gates",23));
ls.addAll(ls2);
ls2.*/
/*List ls3=null;
System.out.println(ls3.isEmpty());*/
/*List ls3=null;
System.out.println(ls2.isEmpty());*/
/*ls.
ls.indexOf(o)
ls.contains(o)*/
//ls2.add(1);
}
}
//ResponseThread 这个是server的先启动client(服务器)再启动它。上面三个类是client放在一个文件夹中
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
import org.apache.log4j.Logger;
/**
* 响应线程,建立ServerSocket响应客户端Socket请求
* @author: sitinspring(junglesong@gmail.com)
* @date: 2007-11-16
*/
public class ResponseThread implements Runnable {
private static Logger logger = Logger.getLogger(ResponseThread.class);
// 用于与客户端通信的Socket
private Socket incomingSocket;
public ResponseThread(Socket incomingSocket) {
this.incomingSocket = incomingSocket;
}
public void run() {
try {
try {
// 输入流
InputStream inStream = incomingSocket.getInputStream();
// 输出流
OutputStream outStream = incomingSocket.getOutputStream();
Scanner in = new Scanner(inStream);
PrintWriter out = new PrintWriter(outStream,true);
while (in.hasNextLine()) {
String line = in.nextLine();
logger.info("从客户端获得文字:"+line);
String responseLine=line+" 门朝大海 三河合水万年流";
out.println(responseLine);
logger.info("向客户端送出文字:"+responseLine);
}
} finally {
incomingSocket.close();
}
} catch (IOException ex) {
ex.printStackTrace();
}
}
public static void main(String[] args) {
try {
ServerSocket socket=new ServerSocket(2009);
logger.info("开始监听");
while(true){
Socket incomingSocket=socket.accept();
logger.info("获得来自"+incomingSocket.getInetAddress()+"的请求.");
ResponseThread responseThread=new ResponseThread(incomingSocket);
Thread thread=new Thread(responseThread);
thread.start();
}
} catch (IOException ex) {
ex.printStackTrace();
}
}
}
展开全部
要用JNI自己用C语言写底层的通信函数,比较麻烦
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
展开全部
应该用socket来通信的。不过具体的还在学习中
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询