idcjp/trafficmonitor
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

trafficmonitor init...1

Browse Source
This commit is contained in:
choi.jh 2025-11-13 09:30:29 +09:00
parent 194ac35d30
commit d1d29e2a2e
1 changed files with 23 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
app/Services/CollectorService.php
View File

@ -13,9 +13,9 @@ use RuntimeException;
class CollectorService extends CommonService class CollectorService extends CommonService
{ {
const OID_IF_IN_OCTETS = '1.3.6.1.2.1.2.2.1.10.'; // ifInOctets (Raw Octets) const OID_IF_IN_OCTETS = '1.3.6.1.2.1.2.2.1.10.'; // ifInOctets (Raw Octets)
const OID_IF_OUT_OCTETS = '1.3.6.1.2.1.2.2.1.16.'; // ifOutOctets (Raw Octets) const OID_IF_OUT_OCTETS = '1.3.6.1.2.1.2.2.1.16.'; // ifOutOctets (Raw Octets)
const SNMP_VERSION = '2c'; const SNMP_VERSION = '2c';
// Counter32의 최대값 + 1 (오버플로우 보정을 위해 사용) // Counter32의 최대값 + 1 (오버플로우 보정을 위해 사용)
const MAX_COUNTER_32BIT = 4294967296; const MAX_COUNTER_32BIT = 4294967296;
public function __construct(CollectorModel $model) public function __construct(CollectorModel $model)
@ -32,7 +32,7 @@ class CollectorService extends CommonService
'title_field' => $this->model->getTitleField(), 'title_field' => $this->model->getTitleField(),
'table' => $this->model->getTable(), 'table' => $this->model->getTable(),
'useAutoIncrement' => $this->model->useAutoIncrement(), 'useAutoIncrement' => $this->model->useAutoIncrement(),
'class_path' => $this->getClassPaths(false) 'class_path' => $this->getClassPaths(false),
]); ]);
} }
return $this->formServiceInstance; return $this->formServiceInstance;
@ -46,7 +46,7 @@ class CollectorService extends CommonService
'title_field' => $this->model->getTitleField(), 'title_field' => $this->model->getTitleField(),
'table' => $this->model->getTable(), 'table' => $this->model->getTable(),
'useAutoIncrement' => $this->model->useAutoIncrement(), 'useAutoIncrement' => $this->model->useAutoIncrement(),
'class_path' => $this->getClassPaths(false) 'class_path' => $this->getClassPaths(false),
]); ]);
} }
return $this->helperInstance; return $this->helperInstance;
@ -77,9 +77,9 @@ class CollectorService extends CommonService
//SNMP연결 //SNMP연결
private function getSNMPOctets(TrafficEntity $trafficEntity, string $oid): ?int private function getSNMPOctets(TrafficEntity $trafficEntity, string $oid): ?int
{ {
$fullOid = $oid . $trafficEntity->getInterface(); $fullOid = $oid . $trafficEntity->getInterface();
$community = $trafficEntity->getCommunity(); $community = $trafficEntity->getCommunity();
$ip = $trafficEntity->getIP(); $ip = $trafficEntity->getIP();
// snmp2_get을 사용하여 SNMP v2c로 요청 // snmp2_get을 사용하여 SNMP v2c로 요청
// 💡 snmp2_get() 함수가 존재하지 않는다는 LSP 오류를 무시하기 위해 @suppress 태그 사용 // 💡 snmp2_get() 함수가 존재하지 않는다는 LSP 오류를 무시하기 위해 @suppress 태그 사용
/** @phpstan-ignore-next-line */ /** @phpstan-ignore-next-line */
@ -98,29 +98,29 @@ class CollectorService extends CommonService
} }
public function getCalculatedData(TrafficEntity $trafficEntity): array public function getCalculatedData(TrafficEntity $trafficEntity): array
{ {
$currentInOctets = $this->getSNMPOctets($trafficEntity, self::OID_IF_IN_OCTETS); $currentInOctets = $this->getSNMPOctets($trafficEntity, self::OID_IF_IN_OCTETS);
$currentOutOctets = $this->getSNMPOctets($trafficEntity, self::OID_IF_OUT_OCTETS); $currentOutOctets = $this->getSNMPOctets($trafficEntity, self::OID_IF_OUT_OCTETS);
if ($currentInOctets === null || $currentOutOctets === null) { if ($currentInOctets === null || $currentOutOctets === null) {
$message = "트래픽 수집 실패: {$trafficEntity->getIP()} - IF{$trafficEntity->getInterface()} (UID: {$trafficEntity->getPK()})"; $message = "트래픽 수집 실패: {$trafficEntity->getIP()} - IF{$trafficEntity->getInterface()} (UID: {$trafficEntity->getPK()})";
log_message('warning', $message); log_message('warning', $message);
throw new Exception($message); throw new Exception($message);
} }
// 이전 데이터를 조회하여 Rate 계산에 사용 // 이전 데이터를 조회하여 Rate 계산에 사용
// $this->model은 TrafficDataModel의 인스턴스라고 가정 // $this->model은 TrafficDataModel의 인스턴스라고 가정
$lastEntity = $this->model->getLastEntity($trafficEntity->getPK()); $lastEntity = $this->model->getLastEntity($trafficEntity->getPK());
$inKbitsSec = 0.0; $inKbitsSec = 0.0;
$outKbitsSec = 0.0; $outKbitsSec = 0.0;
// 이전 데이터가 있어야만 Rate 계산 가능 // 이전 데이터가 있어야만 Rate 계산 가능
if ($lastEntity !== null) { if ($lastEntity !== null) {
$lastTime = Time::parse($lastEntity->getCreatedAt())->getTimestamp(); $lastTime = Time::parse($lastEntity->getCreatedAt())->getTimestamp();
$deltaTime = Time::now()->getTimestamp() - $lastTime; $deltaTime = Time::now()->getTimestamp() - $lastTime;
if ($deltaTime > 0) { if ($deltaTime > 0) {
$lastIn = $lastEntity->getRawIn(); $lastIn = $lastEntity->getRawIn();
$lastOut = $lastEntity->getRawOut(); $lastOut = $lastEntity->getRawOut();
// 💡 1. 인바운드 Octets 차분 계산 (오버플로우 처리) // 💡 1. 인바운드 Octets 차분 계산 (오버플로우 처리)
@ -142,23 +142,24 @@ class CollectorService extends CommonService
// 정상적인 차분 // 정상적인 차분
$deltaOutOctets = $currentOutOctets - $lastOut; $deltaOutOctets = $currentOutOctets - $lastOut;
} }
// Kbit/s 계산: (Delta_Octets * 8 bits) / Delta_Time_Seconds / 1000 (-> Kbit/s) // Kbit/s 계산: (Delta_Octets * 8 bits) / Delta_Time_Seconds / 1000 (-> Kbit/s)
// 실수(float) 연산으로 정확도를 높입니다. // 실수(float) 연산으로 정확도를 높입니다.
$inKbitsSec = ($deltaInOctets * 8.0) / $deltaTime / 1000.0; $inKbitsSec = ($deltaInOctets * 8.0) / $deltaTime / 1000.0;
$outKbitsSec = ($deltaOutOctets * 8.0) / $deltaTime / 1000.0; $outKbitsSec = ($deltaOutOctets * 8.0) / $deltaTime / 1000.0;
} else { } else {
log_message('error', "시간 차이 오류 발생: {$trafficEntity->getIP()} - {$deltaTime}초 (UID: {$trafficEntity->getPK()})"); log_message('error', "시간 차이 오류 발생: {$trafficEntity->getIP()} - {$deltaTime}초 (UID: {$trafficEntity->getPK()})");
} }
} }
// DB에 저장할 데이터를 배열로 반환 // DB에 저장할 데이터를 배열로 반환
return [ return [
// 💡 정수 캐스팅 대신 반올림을 사용하여 정밀도 유지 및 데이터 형식 일치 // 💡 정수 캐스팅 대신 반올림을 사용하여 정밀도 유지 및 데이터 형식 일치
'trafficinfo_uid' => (int)$trafficEntity->getPK(), 'trafficinfo_uid' => (int)$trafficEntity->getPK(),
'in' => round($inKbitsSec, 2), // 소수점 2자리까지 반올림 'in' => round($inKbitsSec, 2), // 소수점 2자리까지 반올림
'out' => round($outKbitsSec, 2), // 소수점 2자리까지 반올림 'out' => round($outKbitsSec, 2), // 소수점 2자리까지 반올림
'raw_in' => (int)$currentInOctets, 'raw_in' => (int)$currentInOctets,
'raw_out' => (int)$currentOutOctets, 'raw_out' => (int)$currentOutOctets,
]; ];
}
} }