【发布时间】:2020-06-04 16:27:49
【问题描述】:
我正在从事一个实习项目,在使用库 jSerialComm 时尝试将 Java 程序与 Arduino Mega 2560 进行通信时遇到了一些问题。 我用usb线连接arduino。
这里的东西,我通过端口将数据发送到卡:/dev/cu.usbmodem1411 所以我把这个端口描述放在方法中:SerialPort.getCommPort("/dev/cu.usbmodem1411"); 但每次我使用方法时:sp.openPort() 我不能打开端口...
这是我在 Java 部分和 Arduino 部分中的代码。
Java程序:
package server;
import cheque.Cheque;
import java.util.*;
import java.io.*;
import java.net.*; // permet de pouvoir faire du réseau avec java
import com.fazecast.jSerialComm.*;
//javac -cp c:\../../classes:c:\../../classes/com/fazecast/jSerialComm-2.6.2.jar -d ../../classes Serveur_trie.java
//java -cp .:c:\../../classes:c:\../../classes/com/fazecast/jSerialComm-2.6.2.jar server.Serveur_trie
// ATTENTION: activer XAMPP avant de lancer le serveur pour que les clients se connectent
public class Serveur_trie extends Thread
{
String name; // nom du client connecté au thread serveur
Socket clientSocket;
ObjectOutputStream out;
private static HashMap<String, Serveur_trie> tableau_nom = new HashMap<String, Serveur_trie>(); // stocke les noms d'utilisateurs dans un tableau
private int algorithme_trie(int num_donnee) // permet de trouver la case pour trier le cheque
{
return num_donnee;
}
private void display_port()
{
SerialPort[] ports = SerialPort.getCommPorts();
for (int i = 0; i < ports.length; i++)
{
System.out.println(ports[i].getSystemPortName());
}
}
private void envoie_donnee_arduino(Integer num_led) throws Exception
// permet d'envoyer les données de l'algorithme à la partie Arduino13
{
display_port();
SerialPort sp = SerialPort.getCommPort("/dev/cu.usbmodem1411"); // port de la carte aruino Mega 2650
sp.setComPortParameters(9600, 8, 1, 0); // default connection settings for Arduino
sp.setComPortTimeouts(SerialPort.TIMEOUT_WRITE_BLOCKING, 0, 0); // block until bytes can be written
if (sp.openPort()) //ouvre le port en question en mode lecture et écriture
{
System.out.println("Port is open");
}
else
{
System.out.println("Failed to open port");
return;
}
System.out.println(num_led.byteValue());
sp.getOutputStream().write(num_led.byteValue()); // écrit les données en BYTE du serveur vers le port
sp.getOutputStream().flush(); // permet de forcet l'écriture des donnés du buffer
Thread.sleep(1000);
if (sp.closePort()) //ferme le port en question en mode lecture et écriture
{
System.out.println("Port is closed :)");
}
else
{
System.out.println("Failed to close port :(");
return;
}
}
public void run() // fonction du thread
{
try (
ObjectOutputStream out = new ObjectOutputStream(clientSocket.getOutputStream());
ObjectInputStream in = new ObjectInputStream(clientSocket.getInputStream());
)
{
Object o = in.readObject();
if (o instanceof Cheque)
{
Cheque cheque = (Cheque) o;
System.out.println("info: " + cheque.get_Num_case());
envoie_donnee_arduino(algorithme_trie(cheque.get_Num_case()));
}
/* else
if(o instanceof String)
{
if( ((String) o).equals("BYE") )
{
break;
}
}*/
}
catch (IOException e)
{
System.err.println("Exception while closing connection!");
}
catch (Exception e)
{
}
}
public Serveur_trie(Socket clientSocket)
{
this.clientSocket = clientSocket;
}
public static void main(String[] args) throws IOException // a executer dans un autre ordinateur
{
Scanner scanner = new Scanner(System.in);
System.out.println("Bienvenue au serveur, Veillez saisir...");
System.out.println("Votre numéro de port >"); // ATTENTION, si vous avez pas le root privilege alors prenez un numéro de port > 1024
int num_port = scanner.nextInt(); // on enregistre le numéro du
try (
ServerSocket serverSocket = new ServerSocket(num_port); // on crée l'application serveur sur un port
)
{
while (true)
{
Serveur_trie server = new Serveur_trie(serverSocket.accept()); // on attend et accepte la demande de connexion d'un client
System.out.println("Client connecté");
server.start();
}
}
catch (IOException e)
{
System.err.println("Exception caught when trying to listen on port " + num_port);
System.err.println(e.getMessage());
}
System.out.println("fermeture du serveur");
scanner.close();
}
}
Arduino 程序:
#include <Wire.h>
const int ref_pin = 1;
void all_led(int dep_led)
{
for (int i = ref_pin; i < ref_pin + 15 ; i++)
{
digitalWrite(i,LOW);
}
delay(1000);
for (int i = ref_pin; i < ref_pin + 15 ; i++)
{
digitalWrite(i,HIGH);
}
delay(1000);
}
void setup()
{
// put your setup code here, to run once:
for (int i = ref_pin; i < 16 ; i++)
{
pinMode(i,OUTPUT);
}
Serial.begin(9600);
while (!Serial)
{
Serial.print("Wait");
; // wait for serial port to connect.
}
//pinMode(11,OUTPUT);
for (int i = ref_pin; i < ref_pin + 15 ; i++)
{
digitalWrite(i,HIGH);
}
Serial.print("Pin ready!");
}
void loop()
{
// put your main code here, to run repeatedly:
if (Serial.available() > 0)
{
byte incomingByte = 0;
incomingByte = Serial.read(); // read the incoming byte:
Serial.print(incomingByte);
if (incomingByte != -1) // -1 means no data is available
{
}
}
//all_led(ref_pin);
提前感谢您的帮助
【问题讨论】:
-
你能不能写一个 Java 程序来打开一些可用的端口——这将有助于证明你的 Java 端没问题。其次,在
setup的循环中检查Serial是否启动并运行,您打印到Serial!这对我来说似乎是个坏主意......如果Serial还不存在,我们如何打印到它?这会导致 Arduino 挂起,让 Java 永远看不到它吗?我不知道。第三,您的两个ref_pin循环可以合并。祝你好运! -
感谢您的回答,我可以打开端口,并且我对 arduino 代码进行了一些更改,但我不知道如何将数据发送到 arduino。每次我尝试这样做时,它都不会注册我发送的数据而是其他数据
-
* 它不注册我发送的数据而是其他数据* - 所以它接收到一些东西但不是你发送的东西?不同的波特率?你打开了 Arduino IDE 吗?还是它的串行监控?它们可能会导致端口繁忙。抱歉,这里只是猜测。